kafka常用命令

// 验证是否有对应topic
kafka-topics --bootstrap-server localhost:9092 --list
kafka-topics --bootstrap-server localhost:9092 --list | grep usertag_datafilter_queue
kafka-topics --bootstrap-server localhost:9092 --topic usertag_datafilter_queue --describe

====>
Topic: usertag_datafilter_queue TopicId: bMlI9apET0ur5CW_bE4YsQ PartitionCount: 3   ReplicationFactor: 1    Configs: segment.bytes=1073741824
    Topic: usertag_datafilter_queue Partition: 0    Leader: 0   Replicas: 0 Isr: 0  Offline:
    Topic: usertag_datafilter_queue Partition: 1    Leader: 0   Replicas: 0 Isr: 0  Offline:
    Topic: usertag_datafilter_queue Partition: 2    Leader: 0   Replicas: 0 Isr: 0  Offline:

kafka-topics --bootstrap-server localhost:9092 --topic usertag_datafilter_queue --delete

kafka-topics --alter --bootstrap-server localhost:9092 --topic usertag_datafilter_queue  --partitions 3


// 验证topic中是否有数据
kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic usertag_datafilter_queue --from-beginning
kafka-console-consumer --bootstrap-server localhost:9092 --topic usertag_datafilter_queue --from-beginning

## 消费指定分区
kafka-console-consumer --bootstrap-server localhost:9092 --topic usertag_datafilter_queue --from-beginning --partition 0