# Logstash Kafka client logs many INVALID\_FETCH\_SESSION\_EPOCH messages

**URL:** <https://discuss.elastic.co/t/logstash-kafka-client-logs-many-invalid-fetch-session-epoch-messages/224822>\
**Category:** Logstash\
**Created:** [March 24, 2020, 11:35am UTC](https://discuss.elastic.co/t/logstash-kafka-client-logs-many-invalid-fetch-session-epoch-messages/224822 "2020-03-24T11:35:43Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![Martin\_K](https://avatars.discourse-cdn.com/v4/letter/m/3e96dc/32.png) [@Martin\_K](https://discuss.elastic.co/u/Martin_K)\
**Post date:** [March 24, 2020, 11:35am UTC](https://discuss.elastic.co/t/logstash-kafka-client-logs-many-invalid-fetch-session-epoch-messages/224822/1 "2020-03-24T11:35:43Z")

</div>

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.`

it's the `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](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?

---

<div class="post-metadata">

**Author:** ![rcowart](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/rcowart/32/88091_2.png) [@rcowart](https://discuss.elastic.co/u/rcowart)\
**Post date:** [March 25, 2020, 9:33am UTC](https://discuss.elastic.co/t/logstash-kafka-client-logs-many-invalid-fetch-session-epoch-messages/224822/2 "2020-03-25T09:33:41Z")

</div>

It looks like the client was updated about a week ago ([https://github.com/logstash-plugins/logstash-integration-kafka/commit/5e7e4d6366fed708e4270ce57ba8210f9743e3dc](https://github.com/logstash-plugins/logstash-integration-kafka/commit/5e7e4d6366fed708e4270ce57ba8210f9743e3dc)). It will probably be in the next release of the plugin.

Rob

[![GitHub](https://us1.discourse-cdn.com/elastic/original/3X/6/f/6f8ae834f16b1a02d31607317669716807844d84.png)](https://github.com/robcowart) [![YouTube](https://us1.discourse-cdn.com/elastic/original/3X/4/3/43b9b81a8c93786219985aeb5335c1c323449053.png)](https://www.youtube.com/channel/UCivWvTx1DwrWNcDLV58kmOg) [![LinkedIn](https://us1.discourse-cdn.com/elastic/original/3X/6/7/674f3370d0f0542ddc5e408516beb1b7edd6c1bf.png)](https://www.linkedin.com/in/robertcowart/)  
**[How to install Elasticsearch & Kibana on Ubuntu - incl. hardware recommendations](https://www.youtube.com/watch?v=gZb7HpVOges)**  
**[What is the best storage technology for Elasticsearch?](https://www.youtube.com/watch?v=nKUpfJCBiS4)**

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [April 22, 2020, 9:46am UTC](https://discuss.elastic.co/t/logstash-kafka-client-logs-many-invalid-fetch-session-epoch-messages/224822/3 "2020-04-22T09:46:04Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.