assertionerror对kafka消费者的影响

ryevplcw 于 2021-06-07 发布在 Kafka

关注(0)|答案(2)|浏览(449)

我正在尝试用kafka处理meetup rsvp流api。
过程如下：
启动zookeeper
开始Kafka
启动Cassandra
运行rsvp\u producer.py
运行rsvp_consumer.py<-我来了。
当我试着运行rsvpïu 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']}

有人能告诉我怎么纠正这个错误吗？
谢谢

cassandra python apache-kafka

来源：https://stackoverflow.com/questions/35689808/assertionerror-on-kafka-consumer

2条答案

按热度按时间

iyfjxgzm1#

我也有同样的问题，就我的情况来说，那是因为错误的方式初始化Kafka消费者。我把它改成：

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

那就行了

赞(0）回复(0）举报 2021-06-07

mccptt672#

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

赞(0）回复(0）举报 2021-06-07

我来回答

assertionerror对kafka消费者的影响

2条答案

相关问题

热门标签

最新问答