一、kafka 命令总结
1、进入bin目类
cd /opt/program-files/kafka/kf/bin

2、查看所以主题

kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list

3、创建主题topic
./kafka-topics.sh --create --zookeeper zk:2181 --replication-factor 1 --partitions 1 --topic test

4、查看topic详情
kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic report-data-ad
不跟topic则查看所以topic详情
./kafka-topics.sh --describe  --bootstrap-server localhost:9092

5、删除topic
./kafka-topics.sh --delete --zookeeper zk:2181 --topic test

6、消费者
./kafka-console-consumer.sh --bootstrap-server zk:9001 --topic DIMTopic

7、生产者
./kafka-console-producer.sh --broker-list zk:9001 --topic DIMTopic

8、查看topic的offset的情况

kafka-run-class.sh kafka.tools.GetOffsetShell  --broker-list 127.0.0.1.55:9092  --topic bidding

window高版本的kafka操作，高版本的kafka操作不需要指定zk了，只需要执行kafka的端口即可

window高版本的kafka消费主题
kafka-console-consumer.bat --bootstrap-server 172.16.1.61:9092 --topic source.report_data_ad

window高版本的kafka查看主题
kafka-topics.bat --describe  --bootstrap-server 172.16.1.61:9092  --topic source.report_data_ad

window高版本的kafka生产者主题
kafka-console-producer.bat --bootstrap-server 172.16.1.61:9092  --topic source.flink-kafka-test

window高版本的kafka创建主题
kafka-topics.bat --create --bootstrap-server 172.16.1.61:9092 --replication-factor 1 --partitions 1 --topic source.flink-kafka-test
 

查看消费组消费的偏移量
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group bidding

列出所有主题中的所有用户组
kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092  --list

设置主题消息过期时间60000毫秒
kafka-configs.bat --bootstrap-server 172.16.1.61:9092  --alter --entity-name source.ad_report_data --entity-type topics --add-config retention.ms=60000

消费主题消息-从头消费
kafka-console-consumer.bat --bootstrap-server 172.16.1.61:9092 --topic source.report_data_ad --from-beginning 

查看主题描述
kafka-configs.bat --bootstrap-server 172.16.1.61:9092 --describe --entity-type topics --entity-name source.report_data_ad