KafkaTimeoutError: Batch for TopicPartition(topic=‘topic_xxx‘, partition=0) containing 1 record(s)
Posted zhangphil
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了KafkaTimeoutError: Batch for TopicPartition(topic=‘topic_xxx‘, partition=0) containing 1 record(s)相关的知识，希望对你有一定的参考价值。
python访问kafka报错，内容样式如下：
KafkaTimeoutError: Batch for TopicPartition(topic='topic_xxx', partition=0) containing 1 record(s) expired: 30 seconds have passed since batch creation plus linger time
原因是kafka服务器端的监听IP地址没设置正确。参照这篇文章设置即可：
https://zhangphil.blog.csdn.net/article/details/126775108以上是关于KafkaTimeoutError: Batch for TopicPartition(topic=‘topic_xxx‘, partition=0) containing 1 record(s)的主要内容，如果未能解决你的问题，请参考以下文章