天天看点

远程连接kafka超时问题

异常一: Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for topic1-0: 30025 ms has passed since batch creation plus linger time

--出现此异常的原因在于listeners未配置

    --解决方式一:在kafka/config目录下的server.properties配置 advertised.listeners=PLAINTEXT://192.168.11.63:9092或listeners=PLAINTEXT://192.168.11.63:9092(此处的ip地址需与kafka所在主机的hostname保持一致)

远程连接kafka超时问题
远程连接kafka超时问题

    --解决方式二:若kafka为0.10.x之前:则可以试试在server.properties中配置advertised.host.name和advertised.port参数(0.10.x版本之后弃用了这俩个属性,改为advertised.listeners)

异常二: Failed to update metadata after 60000 ms.

    --此异常的出现的时候,多半是网络问题,检查/etc/hosts中的主机ip映射的hostname与配置的listeners中的hostname是否保持一致即可,如下图所示:

远程连接kafka超时问题
远程连接kafka超时问题