通过命令行操作kafka的topic_容器化kafka如何使用命令查询topic消息

作者：小桥流水78 | 2024-08-04 01:51:25

踩

容器化kafka如何使用命令查询topic消息

创建 topic

./kafka-topics.sh --create -zookeeper ****:2181 --topic dgaprobdomainurl --partitions 5 --replication-factor 3

查看topic
./kafka-topics.sh --zookeeper ****:2181 -describe --topic networkAccessAgent

# 开一个终端作为consumer 实时获取消息
./kafka-console-consumer.sh --bootstrap-server ****:9092 --topic test-topic --from-beginning

./kafka-console-consumer.sh --bootstrap-server ****:9092 --topic domainurlfromdw --max-messages 1 --from-beginning

删除topic

./kafka-topics.sh --delete -zookeeper ****:2181 --topic p13_anomaly_detection_topic

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小桥流水78/article/detail/925772