"Killed" в stdout? В частном случае перед этим сообщением получаю:
%4|1653269344.668|SESSTMOUT|rdkafka#consumer-1| [thrd:main]: Consumer group session timed out (in join-state steady) after 11210 ms without a successful response from the group coordinator (broker 2, last error was Success): revoking assignment and rejoining group
%5|1653269344.922|REQTMOUT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/2: Timed out HeartbeatRequest in flight (after 11144ms, timeout #0)
%4|1653269345.178|REQTMOUT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/2: Timed out 1 in-flight, 0 retry-queued, 0 out-queue, 0 partially-sent requests
%3|1653269345.178|FAIL|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator: localhost:9092: 1 request(s) timed out: disconnect (after 16688135ms in state UP)
я думаю, вам лучше адресовать вопрос сюда: @proKafka
Это сообщения от librdkafka о том, что не проходят хартбиты. Клиент периодически общается с брокером на предмет "я ещё тут, а ты ещё тут?". Вот в нашем случае получается, что на хартбит клиента никто не отвечает, как я понимаю. Тогда клиент решает, что что-то умерло и пытается перезайти в группу. Тут, скорее всего, не столько клиента надо дебагить, сколько смотреть, почему брокер не отвечает. А если и дебагить, то скорее всего не хаскельную оболочку, а сам протокол в librdkafka. Можно попробовать выставить своёство debug (см. здесь: https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md) и посмотреть что оно напишет, например. https://hackage.haskell.org/package/hw-kafka-client-5.0.0/docs/Kafka-Consumer.html#t:KafkaDebug https://hackage.haskell.org/package/hw-kafka-client-5.0.0/docs/Kafka-Consumer.html#v:debugOptions
Обсуждают сегодня