kafka控制台使用者不使用来自生产者的数据

nom7f22z  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(232)

Kafka版本:Kafka2.11-0.11.0.1
当我尝试在多节点kafka生态系统中从生产者向消费者发送消息时,消息正在被发送,并从kafka服务器进行广播!这些消息可以通过使用kafka consumer通过zookeeper读取[下面的版本将不推荐使用zookeeper!],也可以通过 kafka-simple-consumer-shell.sh ```
./bin/kafka-simple-consumer-shell.sh --broker-list :9092 --topic myTopic

但不能通过消费者引导服务器从消费者中读取!
通过zookeeper服务器呼叫消费者:

./bin/kafka-console-consumer.sh --topic myTopic --zookeeper :2181 --from-beginning

通过引导服务器调用消费者:

./kafka-console-consumer.sh --topic myTopic --bootstrap-server :9092 --consumer.config ../config/consumer.properties

我的 `config/producer.properties` 包含:
bootstrap.servers={broker ip}:9092
compression.type=无
我的 `config/consumer.properties` 包含(无):

# zookeeper.connect={private-ip-1}:2181,{private-ip-2}:2181

# 连接zookeeper超时(毫秒)

# zookeeper.connection.timeout.ms=6000

# 消费者组id

group.id=测试使用者组

# 使用者超时

# consumer.timeout.ms=7000

# consumer.timeout.ms=-1

我的 `config/server.properties` 包含:
侦听器=纯文本://{private-ip-1}:9092
advised.host.name={private-ip-1}
advised.listeners=纯文本://{private-ip-1}:9092
播发端口=9092
host.name={private-ip-1}
zookeeper.connect={private-ip-1}:2181

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题