Кафки (версия 6.0 от confluent).
Время от времени возникают такие ошибки:
Error sending fetch request
Group coordinator <name> (id: <> rack: null) is unavailable or invalid, will attempt rediscovery
Ошибка плавающая. Пару дней может не быть, а потом несколько раз подряд. Тут советуют выставить brocker_id, но он и так етсь (https://stackoverflow.com/questions/40316862/the-group-coordinator-is-not-available-kafka) а тут (https://github.com/spring-projects/spring-kafka/issues/1367?ysclid=l8socdyqfn351490016 ) - уменьшить max.records.per.poll, но он и так 1.
Также нашёл неразрешённую проблему тут: https://issues.apache.org/jira/browse/KAFKA-7697
У меня были какие-то подобные симптомы, но в моём случае а) был кластер кафки, но фактор репликации топика был равен 1 б) это всё было на медленных ceph дисках и кафка почти постоянно уходила в ребаланс, а так как лидер партиции (и реплика) была одна, но были подобные ошибки
Обсуждают сегодня