[大数据]解决KafkaTimeoutError: Batch for TopicPartition

报错具体内容如下：

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超时，需要看一下kafka的配置参数（/config/server.properties）：

listeners=PLAINTEXT://11.20.47.7:9092
advertised.listeners=PLAINTEXT://localhost.localdomain1:9092

这里的 listeners 和advertised.listeners 的值配置的不同，导致的，应改成一致的。

listeners=PLAINTEXT://11.20.47.7:9092
advertised.listeners=PLAINTEXT://11.20.47.7:9092

问题解决。