基于控制台的 dockerized kafka 消费者答案

【问题标题】：Console based consumer for dockerized kafka基于控制台的 dockerized kafka 消费者
【发布时间】：2020-11-14 05:25:31
【问题描述】：

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

【问题讨论】：

Kafka 发行版中的kafka-console-consumer 工具可以工作，尽管它可能需要一些调整。你已经试过了吗？您是否遇到了特定错误？
你使用的是什么版本的 Kafka？

标签： docker apache-kafka apache-zookeeper kafka-consumer-api messagebroker

【解决方案1】：

Kafka 备忘单 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

【讨论】：