启动kafka,windows 命令
在cmd中进入kafka根目录。输入以下命令:
.\bin\windows\kafka-server-start.bat .\config\server.properties
创建kafka producer
kafka-console-producer.bat --broker-list localhost:9092 --topic test
创建consumer
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test1
查看某个topic的信息
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test1 --from-beginning
创建topic
在cmd中进入kafka\bin\windows目录,输入以下命令:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
或者
bin/kafka-topics.sh --create --zookeeper bigdata.ibeifeng.com:2181/kafka08 --replication-factor 1 --partitions 1 --topic hello_topic
linux下的命令
查看linux下某个topic的信息
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic jss_local_1_statspace --from-beginning
查看 kafka 消费者组列表:
./bin/kafka-consumer-groups.sh --bootstrap-server :9092 --list
查看 kafka 中某一个消费者组的消费情况:
./bin/kafka-consumer-groups.sh --bootstrap-server :9092 --group test-17 --describe
查看所有topic
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list
[kafka,查看指定group下topic的堆积数量]
./kafka-consumer-groups.sh --bootstrap-server 10.1.16.73:9092 --describe --group track-consumer-group