时间戳

首页 > 解决方案 > Kafka 服务自动关闭

java - Kafka 服务自动关闭

问题描述

目前我正在使用带有 Java 服务（Spring-boot）的 kafka_2.12-2.5.0。我曾经启动zookeeper kafka，然后先启动debezium服务，它们曾经成功运行。之后，如果我尝试运行 java 服务，那么 kafka 服务会在一段时间内关闭在那个时候 Debezium 连续显示这些日志：

[2020-10-09 06:45:58,503] WARN [Producer clientId=connector-producer-sql-server-connection-0] Connection to node 0 (vsi-kafka-dev-01.c.presence-ss.internal/10.128.15.238:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:762)

同时Java服务不断显示这些日志：

[2020-10-09 11:11:39.635 [org.springframework.kafka.KafkaListenerEndpointContainer#9-0-C-1] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-4, groupId=vsiconsumers] Connection to node 0 (vsi-kafka-dev-01.c.presence-ss.internal/10.128.15.238:9092) could not be established. Broker may not be available.

我在 sh 文件中使用了默认属性，只是更改了 DB 和 IP 相关的更改。

标签： javaapache-kafkadebezium

解决方案

推荐阅读