kafka1.0.0集群搭建

时间：2018-03-02 15:35:25 阅读：296 评论：0 收藏：0 [点我收藏+]

一、环境准备
1、软件
zookeeper3.4.11 https://www.apache.org/dyn/closer.cgi?path=/kafka/1.0.0/kafka_2.11-1.0.0.tgz
kafka1.0.0 http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.11/
java8 http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
2、硬件
? 机器：10.205.104.55
? 机器：10.205.102.52
? 机器：10.205.105.33
二、安装
jdk安装略
1、统一目录/opt
技术分享图片

2、安装zookeeper（三台机器同样操作）
cp conf/zoo_sample.cfg zoo.cfg
grep ^[^#] conf/zoo.cfg
技术分享图片

添加机器id到 dataDir=/opt/zookeeper-3.4.11/data目录下的myid文件中
机器：10.205.104.55 ==1
机器：10.205.102.52 ==2
机器：10.205.105.33 ==3
技术分享图片

每台机器都是同样的配置
启动zookeeper
bin/zkServer.sh start
检验
技术分享图片

3、安装kafka（每台机器broker.id不同。这里依此是0，1，2）
每台机器依此配置
技术分享图片

启动kafka（每台都启动）
bin/kafka-server-start.sh config/server-1.properties &
校验
技术分享图片

创建topic
bin/kafka-topics.sh --create --zookeeper 10.205.104.55:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic
查看topic信息
bin/kafka-topics.sh --describe --zookeeper 10.205.104.55:2181 --topic my-replicated-topic
技术分享图片

推送信息
bin/kafka-console-producer.sh --broker-list 10.205.104.55:9092 --topic my-replicated-topic
消费信息
bin/kafka-console-consumer.sh --bootstrap-server 10.205.104.55:9092 --from-beginning --topic my-replicated-topic
安装完毕

kafka1.0.0集群搭建

原文：http://blog.51cto.com/leizhu/2075724

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年09月23日 (328)
2021年09月24日 (313)
2021年09月17日 (191)
2021年09月15日 (369)
2021年09月16日 (411)
2021年09月13日 (439)
2021年09月11日 (398)
2021年09月12日 (393)
2021年09月10日 (160)
2021年09月08日 (222)