我使用pykafka从kafka主题中获取消息,然后进行一些处理并更新到mongodb。因为pymongodb每次只能更新一项,所以我启动了100个进程。-2.5.0.dev1-py2.7-linux-x86_64.egg/pykafka/balancedconsumer.py", line 745, in __iter__ File "/data/share/python2.7/lib/p
我正在使用pykafka,我可以得到主题名称,但我不能发送信息。producer.produce(b"message") raise ProduceFailureError("Delivery report not received after timeout")
pykafka.exceptions.ProduceFailureError
我在python的pykafka中使用KafkaClient。我正在尝试读取一个文本文件,并将其行指向一个主题,然后由消费者读取它。我的制片人是 from pykafka import KafkaClient
text = text.split()for i in text:
producer.produce(i.encode('as