kafka消费者上的AssertionError

Question

我正在尝试使用kafka处理Meetup RSVP流api。

过程如下：

• 开始动物园管理员
• 开始卡夫卡
• 开始卡桑德拉
• 运行rsvp_producer.py
• 运行rsvp_consumer.py < - 我在这里。

当我尝试运行rsvp_consumer.py时，在Mac上的终端中出现以下错误。

$ python rsvp_consumer.py 
Traceback (most recent call last): 
    File "rsvp_consumer.py", line 12, in <module> 
    metadata_broker_list = kafka_brokers_list) 
    File "/Users/kimitakanakazawa/anaconda/lib/python2.7/site-packages/kafka/consumer/group.py", line 169, in __init__ 
    assert not configs, 'Unrecognized configs: %s' % configs 
AssertionError: Unrecognized configs: {'metadata_broker_list': ['localhost:9092']} 

有人能告诉我如何解决这个错误？

感谢

Answer 1

我有同样的问题恰好，我的情况，那是因为错误的方式给init卡夫卡消费者。我把它改为：

consumer = KafkaConsumer(bootstrap_servers='192.168.33.10:9092', auto_offset_reset='earliest') 
consumer.subscribe(['topic_name']) 

然后它

Answer 2

配置密钥metadata_broker_list在最近的版本改为bootstrap_servers。您可以编辑rsvp_consumer.py，也可以安装旧版本的kafka-python：pip install kafka-python==0.9.5