169 похожих чатов

Всем привет, можете подсказать способ дебага в случае появления сообщения

"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)

2 ответов

12 просмотров

я думаю, вам лучше адресовать вопрос сюда: @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

Похожие вопросы

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта