Получить статус сердцебиения Kafka в приложении на C #

#c# #.net #.net-core #heartbeat

#c# #.net #.net-ядро #сердцебиение

Вопрос:

У меня есть приложение на C #, которое использует Confluent.Kafka . Я вижу, что ConsumerConfig у HeartbeatIntervalMs него есть метод, который устанавливает интервал сердцебиения. Затем ConsumerConfig используется в ConsumerBuilder вызове. Я нигде не вижу, что сердцебиение применяется. Есть ли какой-нибудь способ получить какой-то статус сердцебиения?

Комментарии:

1. Вы проверяли эту ссылку — chrzaszcz.dev/2019/06/ кафка-сердцебиение-нить ? Возможно, это могло бы дать некоторое представление об этой теме.

2. Да, я следил за этим, но поскольку в примерах используется Kotlin (я думаю), я пытаюсь интерпретировать то, что он мне говорит. Просто еще не до конца понимаю это.