Kafka

基本命令

--创建一个主题
bin/kafka-topics.sh --create --bootstrap-server 192.168.31.131:9092 --replication-factor 1 --partitions 1 --topic test
bin/kafka-topics.sh --create --bootstrap-server 192.168.31.131:9092 --replication-factor 2 --partitions 3 --topic test(复制因子为2,分区为3。表示主题test会创建到三台kafka上,且各持有一份备份)
--查看所有主题
bin/kafka-topics.sh --list --bootstrap-server 192.168.31.131:9092 
--生产者
bin/kafka-console-producer.sh --broker-list 192.168.31.131:9092 --topic test
--消费者
bin/kafka-console-consumer.sh --bootstrap-server 192.168.31.131:9092 --topic test --from-beginning
--查看消息日志内容(了解)
bin/kafka-run-class.sh kafka.tools.DumpLogSegments --files /tmp/kafka-logs/test-0/00000000000000000000.log --print-data-log

--查看消费者分组情况、详细信息、删除分组、查看组员

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092 --list
bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092 --group 分组名 --describe
bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092 --group 分组名 --delete

bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092  --describe --group 分组名 --members

使用bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092可以查看所有命令的使用。

"我们所要追求的,永远不是绝对的正确,而是比过去的自己更好"
原文地址:https://www.cnblogs.com/zomicc/p/12410482.html