使用Shell客户端操作kafka

在master上创建一个test1主题

/opt/kafka/kafka_2.10-0.9.0.1/bin/kafka-topics.sh --create --topic test1 --replication-factor 3 --partitions 2 --zookeeper master:2181

replication-factor的几个不能超过Kafkar集群的broker数据

在master上查看刚才创建的test1主题

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

test1

在zkCli上查看主题

[zk: localhost:2181(CONNECTED) 16] ls /brokers/topics

[test1]

在slave1上发送消息至kafka，发送消息“hello kafka”

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

hello kafka

在master上开启一个消费者，可以看到刚才发送的消息

[hadoop@master kafka_2.10-0.9.0.1]$ bin/kafka-console-consumer.sh --zookeeper master:2181 --topic test1 --from-beginning

hello kafka

删除掉一个Topic

bin/kafka-topics.sh --delete --topic test1 --zookeeper master:2181

Topic test1 is marked for deletion.

Note: This will have no impact if delete.topic.enable is not set to true.

这条命令其实并不执行删除动作，仅仅是在zookeeper上标记该topic要被删除而已，同时也提醒用户一定要提前打开delete.topic.enable开关，否则删除动作是不会执行的

同时在zookeeper（假设你的chroot就是/）的/admin/delete_topics下创建一个临时节点，名字就是topic名称