卡夫卡消费者的断言错误答案

【问题标题】：AssertionError on kafka consumer卡夫卡消费者的断言错误
【发布时间】：2016-03-15 12:24:24
【问题描述】：

我正在尝试使用 kafka 处理 Meetup RSVP 流媒体 API。

流程如下：

启动 Zookeeper
启动 Kafka
启动 Cassandra
运行 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']}

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

谢谢

【问题讨论】：

标签： python cassandra apache-kafka

【解决方案1】：

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

【讨论】：

【解决方案2】：

对于我的情况，我完全有同样的问题，那是因为初始化 kafka 消费者的方法错误。我把它改成：

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

然后就可以了

【讨论】：