Getting error INVALID_FETCH_SESSION_EPOCH in logstash

I am getting the error INVALID_FETCH_SESSION_EPOCH while reading messages from kafka.

The error I get is as below.

[2018-07-10T17:42:20,547][INFO ][org.apache.kafka.clients.FetchSessionHandler] [Consumer clientId=logstash-3, groupId=logstash] Node 0 was unable to process the fetch request with (sessionId=1078722252, epoch=278837): INVALID_FETCH_SESSION_EPOCH.

Below is my config

input {
kafka
{
codec => json
bootstrap_servers => "10.24.141.0:9092"
topics => ["syslog-topic","dmesg-topic"]
consumer_threads => 4
partition_assignment_strategy => "org.apache.kafka.clients.consumer.RoundRobinAssignor"
}
}
output
{
if [tag]
{
elasticsearch {
hosts => "localhost:9200"
index => manual_logs_error
}
}
elasticsearch {
hosts => "localhost:9200"
index => manual_logs
}
}

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