原文:Kafka消费时报错:Producer connection to xxx:9092 unsuccessful

使用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 推荐指数:

查看详情

kafka 9092端口不通

在linux搭建完kafka启动成功后,在windows上用telnet测试9092端口是否能不能通的时候,发现端口telent不通,我防火墙已经关闭,用netstat命令查看端口占用也没问,后来尝试了修改各种配置后发现server.properties配置文件listeners ...

Tue Jun 08 05:18:00 CST 2021 0 2205
Kafka系列2-producer和consumer报错

1. 使用127.0.0.1启动生产和消费进程: 1)启动生产者进程: bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test 输入消息: this is msg 生产者进程报错 ...

Wed Jan 18 23:20:00 CST 2017 0 1817
golang中使用kafka客户端sarama消费时需要注意的一个点

kafka消费者的Consume()方法会阻塞; 当Consume()方法返回err时,不确定继续消费有没有问题;保险起见,退出进程,然后重新初始化。 当Consume()方法返回nil是,是可以继续消费的,亲测有效。 需要注意的点写在了注释里: ...

Wed Apr 21 23:44:00 CST 2021 0 784
kafka消费者启动报错

报错信息:  WARN Fetching topic metadata with correlation id 14 for topics [Set(test)] from broker [BrokerEndPoint(2,ubuntu,9092)] failed ...

Sat Jan 19 00:19:00 CST 2019 0 1096
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM