#c# #.net #.net-core #heartbeat
#c# #.net #.net-ядро #сердцебиение
Вопрос:
У меня есть приложение на C #, которое использует Confluent.Kafka
. Я вижу, что ConsumerConfig
у HeartbeatIntervalMs
него есть метод, который устанавливает интервал сердцебиения. Затем ConsumerConfig
используется в ConsumerBuilder
вызове. Я нигде не вижу, что сердцебиение применяется. Есть ли какой-нибудь способ получить какой-то статус сердцебиения?
Комментарии:
1. Вы проверяли эту ссылку — chrzaszcz.dev/2019/06/ кафка-сердцебиение-нить ? Возможно, это могло бы дать некоторое представление об этой теме.
2. Да, я следил за этим, но поскольку в примерах используется Kotlin (я думаю), я пытаюсь интерпретировать то, что он мне говорит. Просто еще не до конца понимаю это.