zoukankan      html  css  js  c++  java
  • kafka基础:解决org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for xxx topic

    https://my.oschina.net/kyle1970/blog/2396318/print

    kafka 0.9.x以后的版本,有一个配置属性叫advertised.listeners,在server.properties中,该属性默认是注释掉的,解释如下:

    #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().
    #advertised.listeners=PLAINTEXT://192.168.14.140:9092

    "PLAINTEXT"表示协议,可选的值有PLAINTEXT和SSL,hostname可以指定IP地址,也可以用"0.0.0.0"表示对所有的网络接口有效,如果hostname为空表示只对默认的网络接口有效

    也就是说如果你没有配置advertised.listeners,就使用listeners的配置通告给消息的生产者和消费者,这个过程是在生产者和消费者获取源数据(metadata)。如果都没配置,那么就使用java.net.InetAddress.getCanonicalHostName()返回的值,对于ipv4,基本就是localhost了

    然后你的生产者就会一直卡死,没有反应,如果添加slf4j 桥接 log4j,将日志级别调到debug,发现如下的日志输出

    Updated cluster metadata version 2 to Cluster(nodes = [Node(0, 127.0.0.1, 9092)], partitions = [])
    [cas-client-proxy] TRACE [main] org.apache.kafka.clients.producer.KafkaProducer.waitOnMetadata(374) | Requesting metadata update for topic topic_9527.

    可以看到客户端连接127.0.0.1:9092而不是你期望的服务器的地址!!!
    如果按照0.8.x配置host.name和port属性,会报如下问题

    org.apache.kafka.clients.producer.KafkaProducer.send(348) | Exception occurred during message send:
    org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

    本文地址:https://my.oschina.net/kyle1970/blog/2396318

    原文地址:http://www.javacoder.cn/?p=849

    解决方法为:
    
    将
    
    advertised.listeners=PLAINTEXT://your.host.name:9092
    
    改为
    
    advertised.listeners=PLAINTEXT://192.168.1.122:9092

    192.168.1.122是kafka服务器的ip地址

  • 相关阅读:
    更改sql server数据库所有者的对象
    对C#委托及事件委托的理解
    印度人是怎样开发软件的?
    SQL常用函数
    Ajax学习1
    Ajax学习2
    什么是ORM?
    jQuery 移动网页到制定的位置
    Juery 控件的取值赋值
    js禁用滚动条
  • 原文地址:https://www.cnblogs.com/qiu-hua/p/13455362.html
Copyright © 2011-2022 走看看