Kafka集群的搭建

时间：2017-03-06 20:34:28 阅读：233 评论：0 收藏：0 [点我收藏+]

Kafka集群的搭建

node1 node2 node3

kafka须用版本(kafka-0.8.2.2)，否则不兼容spark1.6

1.启动zookeeper集群node1 node2 node3

zkServer.sh start

zkServer.sh status

2.修改kafka中的配置文件server.properties（broker.id 和 zookeeper.connect）

broker.id =0 || broker.id=1
port =9092
log.dirs =/tmp/kafka-logs 并不是存放的kafka日志，而是实际的数据
leader的均衡机制，默认为true
zookeeper.connect = node1:2181,node2:2181,node3:2181

node1

node2

node3

3.启动kafka集群--测试kafka可用性

第一步：

因为kafka没有主从关系，所以集群中的每一台都需要启动Kafka

nohup /home/kafka_2.10-0.8.2.2/bin/kafka-server-start.sh /home/kafka_2.10-0.8.2.2/config/server.properties &

node1,node2,node3启动命令（启动时编写的脚本中需要指定server.properties）

chmod +x start-kafka.sh

./start-kafka.sh

第二步：

创建topic

/home/kafka_2.10-0.8.2.2/bin/kafka-topics.sh --create --zookeeper node1:2181,node2:2181,node3:2181--replication-factor 3--partitions 3--topic kfk

chmod +x create-topic.sh

./create-topic.sh

第三步：

node1查看刚刚创建的topic

/home/kafka_2.10-0.8.2.2/bin/kafka-topics.sh --list --zookeeper node1:2181,node2:2181,node3:2181

chmod +x list-topic.sh

同样在node2,node3中均可以看到在node1上创建的topic

第四步：

在node1中创建生产者,在node2中创建消费者,node1中生产，查看node2中是否能够消费

node1

vi producer-topic.sh

/home/kafka_2.10-0.8.2.2/bin/kafka-console-producer.sh --broker-list node1:9092,node2:9092,node3:9092--topic kfk

chmod +x producer-topic.sh

./producer-topic.sh

node2

vi consumer-topic.sh

/home/kafka_2.10-0.8.2.2/bin/kafka-console-consumer.sh --zookeeper node1:2181,node2:2181,node3:2181--from-beginning --topic kfk

chmod +x consumer-topic.sh

./consumer-topic.sh

附件列表

Kafka集群的搭建

原文：http://www.cnblogs.com/haozhengfei/p/18aa97eb0fd855c3c19f5fa0f09cfaa9.html

踩

(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)