docker - 基于控制台的 dockerized kafka 消费者

Question

我有运行 kafka 的 docker 容器。推送消息后，我想运行基于控制台的消费者并收听特定主题。有什么办法吗？

Answer 1

卡夫卡备忘单 FYR，
控制台生产者和消费者

kafka-console-consumer --zookeeper localhost:2181/kafka --topic  topic_name --from-beginning
kafka-console-producer --broker-list localhost:9092 --topic topic_name
kafka-topics --zookeeper localhost:2181/kafka --list

主题详情 & 删除主题

kafka-topics --describe --zookeeper localhost:2181/kafka --topic topic_name
kafka-configs --zookeeper localhost:2181/kafka --alter --entity-type topics --entity-name topic_name --add-config retention.ms=1000
kafka-topics --delete --zookeeper localhost:2181/kafka --topic topic_name

查看活跃经纪人

zookeeper-shell localhost:2181/kafka ls /brokers/ids

卡夫卡猫

kafkacat -b localhost:9092 -L | grep topic
kafkacat -C -b localhost:9092 -o -5 -t topic_name