[2018-11-08 14:34:26,655] ERROR Error when sending message to topic test-flink with key: null, value: 7 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
昵称
0 声望
这家伙太懒,什么都没留下
telnet你访问的端口通不通。
[root@centos04 logs]# telnet 192.168.2.135 9092 Trying 192.168.2.135... Connected to 192.168.2.135. Escape character is '^]'.
我看
/logs
下server.log
也没有出现错误提示解决了吗?
没有,网上方法都试了还是不行,求大神指教
这个配置加了么:
listeners=PLAINTEXT://10.xx.xx.56:9092
listeners=PLAINTEXT://192.168.2.135:9092 host.name=192.168.2.135
我这么配的
zookeeper和kafka配置都是按网上经典博客配的,我这就是kafka模拟生产报错。我用的虚拟机,单节点模式
你运行的命令发一下。
开启生产者:
kafka-console-producer.sh \ --broker-list 192.168.2.135:2181 \ --topic test-flink
开启消费者:
kafka-console-consumer.sh \ --zookeeper 192.168.2.135:2181 \ --from-beginning \ --topic test-flink
试试这种:
新生产者(支持0.9版本+)
bin/kafka-console-producer.sh --broker-list 192.168.2.135:9092 --topic test --producer.config
新消费者(支持0.9版本+)
bin/kafka-console-consumer.sh --bootstrap-server 192.168.2.135:9092 --topic test --new-consumer --from-beginning
还是和之前一样的报错
同一台机器,单个集群,命令也在本地执行,telnet都是通的,还报超时,这个就真的没遇到了。
我也有点蒙圈了,方便的话加下我(qq:578075997),麻烦你帮我远程协助看下,非常感谢!
你都换成localhost试试。防火墙也关了
WARN No meta.properties file under dir /root/mylogs/kafka-logs/meta.properties (kafka.server.BrokerMetadataCheckpoint)
日志里唯一一条警告,其他都是info,也没错误,真是服了
localhost也不行,防火墙是设置了开机自动关闭的
你是不是集群还有问题。。主题在吗?
[root@centos04 config]# kafka-topics.sh \ > --list \ > --zookeeper localhost:2181 test-flink [root@centos04 config]#
[root@centos04 config]# kafka-topics.sh \ > --zookeeper localhost:2181 \ > --describe \ > --topic test-flink Topic:test-flink PartitionCount:1 ReplicationFactor:1 Configs: Topic: test-flink Partition: 0 Leader: 0 Replicas: 0 Isr: 0 [root@centos04 config]#
[root@centos04 config]# jps 2804 QuorumPeerMain 20390 ConsoleProducer 21270 Jps 19805 Kafka [root@centos04 config]#
集群配置都是照着配的,配置没错应该
--broker-list 192.168.2.135:2181
2181
是zk的,你要改成9092
还是你眼神犀利,非常感谢
你的答案