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

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






发表于: 11天前   最后更新时间: 11天前   游览量:131
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • telnet你访问的端口通不通。
    • 开启生产者:
      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
            • [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]# 
              • 评论…
                • in this conversation