i am using logstash-input-kafka 8.0.4,logstash 6.1.1
kafka server version 1.0
logstash config
kafka {
group_id => "b2bconsumer-group"
topics => "b2border"
consumer_threads => 1 # number (optional)， default: 1
decorate_events => true # boolean (optional)， default: false
bootstrap_servers=>"a1:9092,a2:9092,a3:9092"
codec => json
client_id => "logstash_b2b3"
max_poll_interval_ms => "600000"
session_timeout_ms => "10000"
}
}
i started three logstash instance,with different client_id. all running normal with some minutes,then i see this log on 3 logstash machine
sending leaveGroup request to coordinator 10.1.1.1
then all 3 logstash instance didn't comsume any kafak infomation.
Pls help
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.