针对Java程序连接Kafka访问TimeoutException的问题(楼主亲测成功)

￡神魔★判官ぃ 2022-11-11 14:55 375阅读 0赞

> 在服务器上启动Kafka程序后，在使用Java去连接访问的时候，报超时的问题

1.  出现的问题如下

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
    SLF4J: Defaulting to no-operation (NOP) logger implementation
    SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
    Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
     at org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:1132)
     at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:831)
     at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:768)
     at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:656)
     at com.lagou.kafka.demo.producer.MyProducer1.main(MyProducer1.java:48)
    Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

1.  解决：需要修改kafka的server.properties

listeners：配置内网

# The address the socket server listens on. It will get the value returned from
    # java.net.InetAddress.getCanonicalHostName() if not configured.
    #   FORMAT:
    #     listeners = listener_name://host_name:port
    #   EXAMPLE:
    #     listeners = PLAINTEXT://your.host.name:9092
    listeners=PLAINTEXT://10.9.xx.xxx:9092

advertised.listeners：配置外网

# Hostname and port the broker will advertise to producers and consumers. If not set,
    # it uses the value for "listeners" if configured.  Otherwise, it will use the value
    # returned from java.net.InetAddress.getCanonicalHostName(). 这里的服务器公网IP是给Java连接用的。不能够配置为内网
    advertised.listeners=PLAINTEXT://117.50.xxx.xx:9092

测试成功：

Connected to the target VM, address: '127.0.0.1:62604', transport: 'socket'
    SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
    SLF4J: Defaulting to no-operation (NOP) logger implementation
    SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
    消息的主题：topic_5
    消息的分区号：0
    消息的偏移量：0
    Disconnected from the target VM, address: '127.0.0.1:62604', transport: 'socket'

在内网机器上访问kafka使用内网的IP

kafka-console-consumer.sh --bootstrap-server 10.9.xx.xx:9092 --topic topic_1 --from-beginning