命令行工具

下载 Apache Kafka 二进制包

请先在控制台上创建Topic：test-topic，参考：Topic创建

请在实际执行中，将以下地址替换成您UKafka集群的接入地址，参考：查看接入点。


./kafka-topics.sh --bootstrap-server 10.9.188.159:9092 --list


./kafka-topics.sh --bootstrap-server 10.9.188.159:9092 --describe --topic test-topic


./kafka-console-producer.sh --bootstrap-server 10.9.188.159:9092 --topic test-topic


./kafka-console-consumer.sh --bootstrap-server 10.9.188.159:9092 --topic test-topic --group test-group --from-beginning

接收消息命令不退出，另开终端执行下述命令


./kafka-consumer-groups.sh --bootstrap-server 10.9.188.159:9092 --list


./kafka-consumer-groups.sh --bootstrap-server 10.9.188.159:9092 --describe --group test-group


./kafka-consumer-groups.sh --bootstrap-server 10.9.188.159:9092 --delete --group test-group