Kafka基本操作

1. 查看topic列表

./kafka-topic.sh --zookeeper slave1:2181,slave2:2181,slave3:2181 --list

1. 创建topic

./kafka-topic.sh --zookeeper slave1:2181,slave2:2181,slave3:2181 --create --topic first --partitions 3 --replication-factor 3

--topic: topic名称
--partition : 指定分区数
--replication-factor: 指定副本数

1. 查看topic详细信息

./kafka-topic.sh --zookeeper slave1,slave2,slave3 --describe --topic first

4. 生产消息

./kafka-console-producer.sh --topic first --broker-list master:9092,slave1:9092,slave2:9092

1. 消费消息

./kafka-console-consumer.sh --bootstrap-server master:9092,slave1:9092,slave2:9092 --topic first