【问题标题】:Kafka-python KafkaProducer __init__ takes 1 positional argument but 2 were givenKafka-python KafkaProducer __init__ 接受 1 个位置参数,但给出了 2 个
【发布时间】:2021-12-08 06:45:37
【问题描述】:

我遇到以下错误:

Traceback (most recent call last):
connection = KafkaProducer(kafka_settings['topic'], bootstrap_servers=kafka_settings['bootstrap_servers'])
TypeError: __init__() takes 1 positional argument but 2 were given

这对我来说很奇怪,因为我遵循了给出的文档。 https://kafka-python.readthedocs.io/en/master/usage.html

我该如何解决这个问题?

【问题讨论】:

  • 我现在在看文档,初始化producer时没有topic名称参数
  • 请澄清您的具体问题或提供其他详细信息以准确突出您的需求。正如目前所写的那样,很难准确地说出你在问什么。

标签: python apache-kafka kafka-python


【解决方案1】:

https://kafka-python.readthedocs.io/en/master/usage.html建议bootstrap_servers是创建KafkaProducer时给的参数,但使用.send方法时需要指定主题,请尝试关注

connection = KafkaProducer(bootstrap_servers=kafka_settings['bootstrap_servers'])
future = connection.send(kafka_settings['topic'], b'your_message_here')

【讨论】:

    猜你喜欢
    • 2020-01-30
    • 2021-10-11
    • 1970-01-01
    • 2017-04-22
    • 2017-11-23
    • 1970-01-01
    • 2020-01-11
    相关资源
    最近更新 更多