In my linux & k8s based VM, I have kafka deployed as statefulset, and debezium connect as deployment object. I get error when debezium tries to connect to kafka.
ERROR: [Producer clientId=1-statuses] Connection to node 0 (kafka-service.my-namespace.svc.cluster.local/:9092) could not be established. Node may not be available. [org.apache.kafka.clients.NetworkClient]
Here’s code snippet:
environment:
clusterId: kafka-cluster-id-1
processRoles: controller,broker
nodeId: 0
kafkaService: kafka-service
listeners: PLAINTEXT://kafka-service.my-namespace.svc.cluster.local:9092,CONTROLLER://localhost:9093
advertisedListeners: PLAINTEXT://kafka-service.my-namespace.svc.cluster.local:9092
listenerSecurityProtocolMap: PLAINTEXT:PLAINTEXT,CONTROLLER:PLAINTEXT
isKRaftEnabled: Yes
controllerListenerNames: CONTROLLER
controllerQuorumVoters: "0@localhost:9093"
And here is the snippet from debezium:
name: debezium-container
image: "{{ .Values.image.debezium.registry }}/{{ .Values.image.debezium.repository }}:{{ .Values.image.debezium.tag }}"
imagePullPolicy: {{ .Values.image.debezium.pullPolicy }}
ports:
- containerPort: 8083
env:
- name: BOOTSTRAP_SERVERS
value: kafka-service.my-namespace.svc.cluster.local:9092
Any idea what’s going on here and why I get the error?
Thanks.