日志中出現以下異常信息,程序中斷退出。
目前參考別人的修改下面的配置,原來使用的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