/application-error-the-connection-to-the-server-was-unsuccessful-file- ...
使用kafka消費數據時報Producer錯誤,具體錯誤如下: kafka.producer.SyncProducer: Producer connection to xxx: unsuccessfuljava.nio.channels.ClosedByInterruptException at java.nio.channels.spi.AbstractInterruptibleChannel. ...
2018-11-12 19:29 0 658 推薦指數:
/application-error-the-connection-to-the-server-was-unsuccessful-file- ...
Started by user test Running as SYSTEM Building remotely on home_windows (mbhCloud_UI_Test) in works ...
命令:./kafka-console-producer.sh --broker-list zookeeper:9092 --topic monitor 啟動kafka生產者報錯: 原因:zookeeper端口號寫錯了! 總結:就算zookeeper端口寫錯了也能運行,但是只有再 ...
在linux搭建完kafka啟動成功后,在windows上用telnet測試9092端口是否能不能通的時候,發現端口telent不通,我防火牆已經關閉,用netstat命令查看端口占用也沒問,后來嘗試了修改各種配置后發現server.properties配置文件listeners ...
1. 使用127.0.0.1啟動生產和消費進程: 1)啟動生產者進程: bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test 輸入消息: this is msg 生產者進程報錯 ...
今天用eclipse連接Hadoop集群的時候突然給我報了這樣一個錯誤:Error:Call From xxx/xxx.xxx.xxx.xxx to hostname1:9000 failed on connection exception:java.net.ConnectException ...
kafka消費者的Consume()方法會阻塞; 當Consume()方法返回err時,不確定繼續消費有沒有問題;保險起見,退出進程,然后重新初始化。 當Consume()方法返回nil是,是可以繼續消費的,親測有效。 需要注意的點寫在了注釋里: ...
報錯信息: WARN Fetching topic metadata with correlation id 14 for topics [Set(test)] from broker [BrokerEndPoint(2,ubuntu,9092)] failed ...