Вчера я обнаружил из журнала, что кафка повторно принимал некоторые сообщения после того, как координатор группы Kafka инициировал ребалансировку группы. Эти сообщения были израсходованы два дня назад (подтверждено из журнала). В журнале было...

Я пытаюсь создать данные в кодировке avro в теме kafka, используя пакет / linkedin / goavro в Go. Цель состоит в том, чтобы иметь возможность использовать тему с использованием разных клиентов. Сначала я регистрирую схему следующим образом:...