Потребитель Кафки не потребляет записи и сбрасывает предложение для раздела-0 в смещение-5 - PullRequest
Новая
       23

Потребитель Кафки не потребляет записи и сбрасывает предложение для раздела-0 в смещение-5

0 голосов
/ 28 апреля 2019

Запуск этого приложения в многоузловом кластере kafka и подключение к сети Docker с использованием 0.0.0.0:19092,0.0.0.0:29092,0.0.0.0:39092. когда я запускаю docker-compose, он печатает log Connection to node -3 (/0.0.0.0:39092) could not be established. Broker may not be available

и после печати некоторые журналы производитель начинает слушать INFO Registered broker 3 at path /brokers/ids/3 with addresses: ArrayBuffer(EndPoint(localhost,39092,ListenerName(PLAINTEXT),PLAINTEXT)) (kafka.zk.KafkaZkClient) kafka-producer_1_c40d8f3bc06f | 2019-04-28 16:42:43 WARN NetworkClient:1023 - [Producer clientId=producer-1] Error while fetching metadata with correlation id 1 : {topic=LEADER_NOT_AVAILABLE}

и потребитель также печатает что-то вроде этого kafka-consumer_1_c9be997eb7fa | 2019-04-28 16:42:44 WARN NetworkClient:1023 - [Consumer clientId=consumer-1, groupId=foo] Error while fetching metadata with correlation id 7 : {topic=LEADER_NOT_AVAILABLE}

kafka-consumer_1_c9be997eb7fa | 2019-04-28 16:33:23 INFO  ConsumerCoordinator:290 - [Consumer clientId=consumer-1, groupId=foo] Setting newly assigned partitions: topic-0
kafka-consumer_1_c9be997eb7fa | 2019-04-28 16:33:23 INFO  Fetcher:584 - [Consumer clientId=consumer-1, groupId=foo] Resetting offset for partition topic-0 to offset 5.```

but if i start running Proudcer application from IDE it consumes records.

why consumer not consuming in docker network?
...