python kafka消费者超时参数_获取溢出错误：使用kafkapython producerconsum时超时值太大...

好吧，我正在尝试使用python中的Kafka python包(1.3.2)来实现从生产者到消费者的简单数据转换。在

制作人：from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers='localhost:9092')

# produce asynchronously

for _ in range(2):

producer.send('my-topic', b'message')

producer.flush()

producer = KafkaProducer()

消费者：

^{pr2}$

我收到以下关于我的消费者的信息：

my-topic:0:5056: key=None value=b'message'

my-topic:0:5057: key=None value=b'message'

但与此同时，我在制作人那里发现了一个错误：

Error in atexit._run_exitfuncs:

Traceback (most recent call last):

File "C:\Users\VNK736\AppData\Local\Programs\Python\Python36-32\lib\site-packages\kafka\producer\kafka.py", line 364, in wrapper

_self.close()

File "C:\Users\VNK736\AppData\Local\Programs\Python\Python36-32\lib\site-packages\kafka\producer\kafka.py", line 420, in close

self._sender.join(timeout)

File "C:\Users\VNK736\AppData\Local\Programs\Python\Python36-32\lib\threading.py", line 1060, in join

self._wait_for_tstate_lock(timeout=max(timeout, 0))

File "C:\Users\VNK736\AppData\Local\Programs\Python\Python36-32\lib\threading.py", line 1072, in _wait_for_tstate_lock

elif lock.acquire(block, timeout):

OverflowError: timeout value is too large

默认情况下，超时设置为NONE，并在Kafka.py中设置为999999999。在我的生产者代码中，我无法在KafkaProducer中找出传递超时的参数。在

有人遇到过这个问题吗？或者有人能帮我这个方向吗。提前谢谢。在