目前,我正在使用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相关的更改。
暂无答案!
目前还没有任何答案,快来回答吧!