Ответ 1
Это было состояние гонки в Кафке - KAFKA-8052.
Это будет исправлено в выпуске 2.3.0.
Почему потребители Kafka выводят INVALID_FETCH_SESSION_EPOCH после обновления до 1.1?
Недавно мы обновили наших брокеров и клиентов Kafka до версии 1.1.1. Начиная с обновления мы периодически видим записи журнала ИНФО, такие как
INFO Jun 08 08:30:20.335 61161458 [KafkaRecordConsumer-0] org.apache.kafka.clients.FetchSessionHandler [Consumer clientId=consumer-1, groupId=group_60_10] Node 3 was unable to process the fetch request with (sessionId=819759315, epoch=145991): INVALID_FETCH_SESSION_EPOCH.
Я вижу, что это сообщение происходит от изменений, внесенных в KIP-227: введение дополнительных запросов Fetch для повышения стабильности раздела. Однако я не могу найти никакой подробной информации о том, почему это сообщение появится или какие параметры, возможно, придется настроить после его введения.
Пока что это, похоже, не влияет на поведение потребителей в отношении получения записей (кроме введения дополнительной задержки), но я хотел бы понять
- Почему сообщение регистрируется?
- Что можно сделать, чтобы остановить это?