kafkaStream執行過程中出現TimeoutException異常退出

 日志中出現以下異常信息，程序中斷退出。

目前參考別人的修改下面的配置，原來使用的hostname，改成IP，再觀察觀察。

 advertised.listeners=PLAINTEXT://192.168.1.101:9092 

listeners一定要配置成為IP地址；
如果配置為localhost或服務器的hostname,在使用java發送數據時可能會拋出異常：
org.apache.kafka.common.errors.TimeoutException: Batch Expired 。
因為在沒有配置advertised.host.name 的情況下，Kafka並沒有廣播我們配置的host.name，而是廣播了主機配置的hostname。
遠端的客戶端並沒有配置 hosts，所以自然是連接不上這個hostname的，也可以在遠端客戶端配置hosts

 

參考：

https://www.cnblogs.com/cyfonly/p/5954614.html

https://blog.csdn.net/sniperken/article/details/52636675