一、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

