【发布时间】: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