Kafka操作指令

一、建立Topic

kafka-topics.sh --create --zookeeper bigdata1:2181 --replication-factor 2 --partitions 2 r--topic test
Created topic test.
           

二、删除Topic

kafka-topics.sh --delete --zookeeper bigdata1:2181 --topic test
Topic test is marked for deletion.
           

三、檢視所有Topic

kafka-topics.sh --list --zookeeper bigdata1:2181
test
           

四、檢視特定的Topic分區數、副本數

kafka-topics.sh --describe --topic first --zookeeper bigdata1:2181
           

五、生産者

kafka-console-producer.sh --broker-list bigdata1:9092 --topic test
>i love you?
>do you love me?

           

六、消費者

kafka-console-consumer.sh --bootstrap-server bigdata1:9092 --topic test --from-beginning
i love you?
do you love me?