zoukankan      html  css  js  c++  java
  • kafka2.10集群搭建(一)

    一.kafka集群搭建

      1.上传解压

      2.配置文件的配置

        1.修改 server.properties文件

    broker.id=11 #192.168.199.11   #21  一般使用ip后三位
    
    listeners=PLAINTEXT://192.168.199.11:9092 #34
    
    log.dirs=/home/pengbo.zhao/data/kafka #63
    
    zookeeper.connect=192.168.199.11:2181,192.168.199.12:2181,192.168.199.13:2181/kafka #119
    //注意:这里后面连接的url后面加了"/kafka",详见kafka server.properties 配置文件详解

      broker.id=12 #192.168.199.12 #21  一般使用ip后三位

      listeners=PLAINTEXT://192.168.199.12:9092 #34

      log.dirs=/home/pengbo.zhao/data/kafka #63

      zookeeper.connect=192.168.199.11:2181,192.168.199.12:2181,192.168.199.13:2181/kafka #119

      broker.id=13 #192.168.199.13 #21  一般使用ip后三位

      listeners=PLAINTEXT://192.168.199.13:9092 #34

      log.dirs=/home/pengbo.zhao/data/kafka #63

      zookeeper.connect=192.168.199.11:2181,192.168.199.12:2181,192.168.199.13:2181/kafka #119

    //注意:这里后面连接的url后面加了"/kafka",详见kafka server.properties 配置文件详解

      3.启动、停止

    bin/kafka-server-start.sh -daemon config/server.properties #采用后台启动的方式启动三台kafka

     bin/kafka-server-stop.sh config/server.properties 

      4.创建topic

    bin/kafka-topics.sh --create --topic test1 --partitions 1 --replication-factor 3 --zookeeper 192.168.199.11:2181/kafka
    //注意:在zk集群模式下,连接1个节点就可以将数据同步了

      查看分布:

    bin/kafka-topics.sh --describe --topic test1 --zookeeper 192.168.199.11:2181/kafka
        

      5.验证topic

      通过console的方式连接控制台,创建生产者

    bin/kafka-console-producer.sh --topic test1 --broker-list 192.168.199.11:9092,192.168.199.12:9092,192.168.199.13:9092

      创建消费者:

    bin/kafka-console-consumer.sh --topic test1 --bootstrap-server 192.168.199.11:9092,192.168.199.12:9092,192.168.199.13:9092

      在producer端任意输入数据,在consumer端可以接收到发送的数据

  • 相关阅读:
    mysql索引需要了解的几个注意
    apache配置--虚拟目录
    简化LINUX的命令输入 简化linux命令 快捷键 短路径
    apache vhost 访问权限配置
    php中常用设置
    win7配置nginx + php
    restful php
    php 笔记 汇总 学习
    mysql修改表结构
    mysql 优化工具
  • 原文地址:https://www.cnblogs.com/MrRightZhao/p/11079969.html
Copyright © 2011-2022 走看看