TypeError:\uyu init_uu（）只接受1个参数（给定2个）

Question

我试图在ubuntu中运行monasca persister组件，但是与kafka相关的文件有一个错误，我的kafka服务器运行良好。在

Process Process-2:
commit_timeout=kafka_conf.max_wait_time_seconds)
File "/usr/local/lib/python2.7/dist-packages/monasca_common/kafka/consumer.py", line 92, in __init__
Traceback (most recent call last):
self._kafka = kafka.client.KafkaClient(kafka_url)
TypeError: __init__() takes exactly 1 argument (2 given)
File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
self.run()
File "/usr/lib/python2.7/multiprocessing/process.py", line 114, in run
self._target(*self._args, **self._kwargs)
File "persister.py", line 126, in start_process
persister = Persister(kafka_config, cfg.CONF.zookeeper, respository)
File "/home/dpeuser/monasca-persister/monasca_persister/repositories/persister.py", line 42, in __init__
commit_timeout=kafka_conf.max_wait_time_seconds)
File "/usr/local/lib/python2.7/dist-packages/monasca_common/kafka/consumer.py", line 92, in __init__
self._kafka = kafka.client.KafkaClient(kafka_url)
TypeError: __init__() takes exactly 1 argument (2 given)
2016-08-31 12:05:55.245 28419 INFO __main__ [-] Received signal 17, beginning graceful shutdown.

所以，我检查了错误的文件，但我不知道是什么错误

^{pr2}$

Answer 1

KafkaClient类不接受任何位置参数。将配置作为关键字参数传入：

self._kafka = kafka.client.KafkaClient(bootstrap_servers=kafka_url)

请参阅source linked from the documentation查看接受哪些配置关键字及其默认值。许多相同的配置选项也记录在^{} class中。在