基于控制台的消费者码头化卡夫卡

Question

我有一个运行kafka的docker容器。一旦我推送消息，我就想运行一个基于控制台的消费者，并从特定的主题中收听。有办法做到这一点吗？

Answer 1

Kafka Cheatsheet 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

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