In our production environment (elastic 7.3) we have a lot of logs from Logstash with the following messages:
[Consumer clientId=metrics_prod-0, groupId=internal_in_metrics_prod] Node 3 was unable to process the fetch request with (sessionId=1631518421, epoch=5480): INVALID_FETCH_SESSION_EPOCH.
logstash.log.module: org.apache.kafka.clients.FetchSessionHandler that logs the message as an INFO
When googling this it seems that this issue could be related to the Kafka client issue reported on https://issues.apache.org/jira/browse/KAFKA-8052
For Kafka client 2.1.0 (which logstash uses) this seems to be an issue. The issue was solved in Kafka client 2.3.0.
Any plans on upgrading to Kafka 2.3.0+ for logstash so this issue can be resolved?