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
暂无答案!
目前还没有任何答案,快来回答吧!