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

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM