kafka服务自动关闭

ddarikpa  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(270)

目前,我正在使用kafkaèu2.12-2.5.0和java服务(spring boot)。我曾经启动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相关的更改。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题