kafka模拟生产报错Failed to update metadata after 60000 ms?

守護愛♚伐木累 发表于: 2018-11-08   最后更新时间: 2018-11-08 14:38:51   23,119 游览

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

发表于 2018-11-08
添加评论

telnet你访问的端口通不通。

[root@centos04 logs]# telnet 192.168.2.135 9092
Trying 192.168.2.135...
Connected to 192.168.2.135.
Escape character is '^]'.

我看/logsserver.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

还是你眼神犀利,非常感谢

你的答案

查看kafka相关的其他问题或提一个您自己的问题