zoukankan      html  css  js  c++  java
  • kafka集群搭建

    准备工作:jdk,zookeeper,kafka(一台虚拟机)

    首先安装zookeeper集群

    一,安装zookeeper放入虚拟机中,解压,复制三台zookeeper到/opt/zookeeper中

      

     二,在每个zookeeper的data目录下创建myid文件,内容分别为0,1,2(记录每个服务器的ID) vi myid    (myid是zookeeper集群用来发现彼此的标识,必须创建,且不能相同)

    三,在每个zookeeper中的conf/zoo.cfg修改data,log目录地址,以及端口号(2181,2182,2183),并且配置客户端访问端口和集群服务IP列表

       server.0、server.1、server.2 为集群信息。

      2888端口号是zookeeper服务之间通信的端口

      3888端口是zookeeper与其他应用程序通信的端口。

     四。依次启动zookeeper(完成zookeeper的搭建)

      启动命令:/opt/zookeeper/zookeeper-01:bin/zkServer.sh start

      查看状态:/opt/zookeeper/zookeeper-01:bin/zkServer.sh status(有leader和follower)

      

       

    kafka集群搭建

       一,安装kafka放入虚拟机中,解压,复制三台kafka到/opt/kafka中

     二,修改每个kafka中的broker.id (0,1,2),端口号 (092,9093,9094)zookeeper的集群地址(localhost:2181,localhost:2182,localhost:2182)

     

     

    三,依次启动kafka三个节点 ,命令:bin/kafka-server.start.sh  ./config/server.properties

    四,在一台上创建主题

      topic  :bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic test --partitions 3  -replication-factor 3

      查看创建的topic信息

       bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test

          

    五,测试:

       启动生产端发送消息:bin/kafka-console-consumer.sh --bootstrap-server loca lhost:9092 --topic test

      

       启动消费端接收消息:bin/kafka-console-producer.sh --broker-list 192.168.117.129:9092 --topic test

      

     完成...

  • 相关阅读:
    ASP.NET 实现邮件发送和接受的功能(Sockets)
    使用Sql server进行分布式查询
    Sqlserver中的一些技巧
    使用sql server中的全文索引
    水晶报表的装载和修改文本
    创建作业的通用存储过程
    MS SQL数据库备份和恢复
    数据库运用XML操作
    安装程序自动安装数据库
    ASP.NET 实现邮件发送和接受的功能(Mail)
  • 原文地址:https://www.cnblogs.com/yangxiaoli/p/13386269.html
Copyright © 2011-2022 走看看