获取溢出错误：使用kafkapython producerconsum时超时值太大

Question

好吧，我正在尝试使用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中找出传递超时的参数。在

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

Answer 1

我认为你的问题可能是因为你使用的是32位的windows。据我所知，kafka python代码中没有对32位的显式支持。在

据我所知，您的实现看起来不错。在