kafka命令行操作

1.查看kafka的消费组

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 127.0.0.1:9092 --list

2.查看组详情

bin/kafka-consumer-groups.sh  --bootstrap-server 127.0.0.1:9092  --describe --group log-consumer

3.查看topics

bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --topic --list 

4.查看topic详情

bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --topic TEST-TOPIC --describe

5.修改topic参数

bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --topic TEST-TOPIC --alter --partitions 10

6.生产测试数据

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic TEST-TOPIC

6.消费测试数据

bin/kafka-console-producer.sh --bootstrap-server 127.0.0.1:9092 --topic TEST-TOPIC

7.创建索引

bin/kafka-topics.sh --create --bootstrap-server 127.0.0.01:9092 --replication-factor 1 --partitions 12 --topic TEST-TOPIC