You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Akshay Sharma (Jira)" <ji...@apache.org> on 2020/08/20 09:50:00 UTC
[jira] [Created] (KAFKA-10423) Logtash is restarting with
invalid_fetch_session_epoch error
Akshay Sharma created KAFKA-10423:
-------------------------------------
Summary: Logtash is restarting with invalid_fetch_session_epoch error
Key: KAFKA-10423
URL: https://issues.apache.org/jira/browse/KAFKA-10423
Project: Kafka
Issue Type: Bug
Components: clients, KafkaConnect, logging
Affects Versions: 2.3.0
Reporter: Akshay Sharma
Logstash(input plugin is kafka) is restarting again and again with error as mentioned below
logs:
```
{{{"log":"[INFO ] 2020-07-27 05:03:43.873 [Ruby-0-Thread-12: /usr/share/logstash/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.3.1/lib/logstash/inputs/kafka.rb:244] FetchSessionHandler - [Consumer clientId=logstash-0, groupId=logstash] Node 1001 was unable to process the fetch request with (sessionId=2115239606, epoch=1128): INVALID_FETCH_SESSION_EPOCH.\n","stream":"stdout","time":"2020-07-27T05:03:43.873634303Z"}
\{"log":"[WARN ] 2020-07-27 05:14:18.976 [SIGTERM handler] runner - SIGTERM received. Shutting down.\n","stream":"stdout","time":"2020-07-27T05:14:18.976808493Z"}
\{"log":"[INFO ] 2020-07-27 05:14:19.030 [Ruby-0-Thread-12: /usr/share/logstash/vendor/bundle/jruby/2.3.0/gems/logstash-input-kafka-8.3.1/lib/logstash/inputs/kafka.rb:244] AbstractCoordinator - [Consumer clientId=logstash-0, groupId=logstash] Sending LeaveGroup request to coordinator ikafka-0.kafka-headless.default.svc.cluster.local:9092 (id: 2147482646 rack: null)\n","stream":"stdout","time":"2020-07-27T05:14:19.031121275Z"}}}
```
KAFKA LOGS
```
{{{"log":"[2020-07-27 05:14:19,031] INFO [GroupCoordinator 1001]: Member logstash-0-9a59ad3d-c6ab-4dba-9775-5974d17934d1 in group logstash has left, removing it from the group (kafka.coordinator.group.GroupCoordinator)\n","stream":"stdout","time":"2020-07-27T05:14:19.032132241Z"}
\{"log":"[2020-07-27 05:14:19,032] INFO [GroupCoordinator 1001]: Preparing to rebalance group logstash in state PreparingRebalance with old generation 85 (__consumer_offsets-49) (reason: removing member logstash-0-9a59ad3d-c6ab-4dba-9775-5974d17934d1 on LeaveGroup) (kafka.coordinator.group.GroupCoordinator)\n","stream":"stdout","time":"2020-07-27T05:14:19.032320407Z"}
\{"log":"[2020-07-27 05:14:19,032] INFO [GroupCoordinator 1001]: Group logstash with generation 86 is now empty (__consumer_offsets-49) (kafka.coordinator.group.GroupCoordinator)\n","stream":"stdout","time":"2020-07-27T05:14:19.032619661Z"}
\{"log":"[2020-07-27 05:15:10,766] INFO [GroupCoordinator 1001]: Preparing to rebalance group logstash in state PreparingRebalance with old generation 86 (__consumer_offsets-49) (reason: Adding new member logstash-0-bde43584-a21e-4a0d-92cc-69196f213f11 with group instanceid None) (kafka.coordinator.group.GroupCoordinator)\n","stream":"stdout","time":"2020-07-27T05:15:10.767053896Z"}}}
```
--
This message was sent by Atlassian Jira
(v8.3.4#803005)