TypeError: produce() got an unexpected keyword argument 'linger_ms'

Question

我正在尝试将 kafka 与 python 和 pykafka 一起使用，当我尝试使用 linger_ms 时出现此错误：

TypeError: produce() 得到了一个意外的关键字参数 'linger_ms'

这是我的代码：

import queue
from pykafka import KafkaClient
client = KafkaClient(hosts="127.0.0.1:9092,127.0.0.1:9093",broker_version="1.0.0")
topic = client.topics['mytopic']

with topic.get_producer(delivery_reports=True) as producer:
     count = 0
     while True:
         count += 1
         producer.produce(
             'test msg'.encode(encoding='UTF-8'), 
             partition_key=('{}'.format(count))
                          .encode(encoding='UTF-8'),
             timestamp=(datetime.datetime.now())+timedelta(seconds=120),
             linger_ms=120000)

Answer 1

Producer 上的 produce() method 不接受 linger_ms 参数。这就是您收到此错误的原因。

初始化Producer时传递linger_ms参数：

with topic.get_producer(delivery_reports=True, linger_ms=120000) as producer:
    ...

TypeError: produce() got an unexpected keyword argument 'linger_ms'

TypeError: produce() got an unexpected keyword argument 'linger_ms'

python

django

apache-kafka

pykafka