kafka集群安装和基本使用

kafka的集群管理是通过zookeeper实现的

第一步zookeeper启动

bin/zookeeper-server-start.sh config/zookeeper.properties

 
第二步kafka启动

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

server.properties中指定zookeeper的地址，用逗号隔开

kafka常用操作命令

1、Create a topic

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

 2、查看所有topic

bin/kafka-topics.sh --list --zookeeper localhost:2181

 3、发送消息（producer。每行一条消息）

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
(输入)This is a message

 4、查看消息（consumer）

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

 5、查看kafka topic分片信息

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