в логах пишут много таких сообщений.
WARN o.a.k.c.NetworkClient [kafka-coordinator-heartbeat-thread |test-conn] [Consumer clientId=test-conn-639df7f9-67f7-4391-a643-d7ad3d9949eb-StreamThread-10-consumer, groupId=test-conn] Connection to node 0 (kafka-broker-0.broker-headless/10.0.5.61:29092) could not be established. Broker may not be available.
k8s, образы confluent, стейтфуллсет. ip-шники нигде не захардкожены. Но видимо стримы пытаются по 10.0.5.61:29092 коннектиться, но так так брокеры были перезапущены, то понятное дело уже не достучаться по этому ip, через telnet проверил - убедился.
В чем может быть проблема?
А почему используются headless брокеры? Тут в чатике говорили, что нужно использовать адрес сервиса кафки (который уже сам резолвится в корректный IP)
Обсуждают сегодня