/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 ...