我在单个节点上运行kafka v1.0.1，我可以将消息推送到主题中，但无法使用下面的python代码使用来自另一个节点的消息。
from kafka import KafkaConsumer
consumer = KafkaConsumer(
'kotak-test',
bootstrap_servers=['kmblhdpedge:9092'],
auto offset reset='earliest',
enable auto commit=True,
group id=' test1',
value_deserializer-lambda x: loads (x.decode('utf-8')))
for message in consumer:
message = message.value
print (message)我经常使用以下命令从控制台推送消息：
bin/kafka-console-producer --zookeeper <zookeeper-node>:<port> --topic <topic_name>我还可以通过控制台阅读
1条答案
按热度按时间bwleehnv1#
你使用的是老的zookeeper制作人，但新的kafka消费者。这些偏移量的工作原理和存储偏移量的逻辑不同。
你需要使用
--broker-list在控制台上与控制台使用者类似，使用
--bootstrap-server，不是--zookeeper此外，这些属性中不应包含空格