logstash-plugins/logstash-output-kafka

How to set max.in.flight.requests.per.connection ?

Opened this issue · 1 comments

olivetree123 commented

I want to output data to kafka in order, so I want to set max.in.flight.requests.per.connection to 1.
How to do ?

cclient commented

https://github.com/cclient/logstash-output-kafka

modify and rebuild

  props.put(kafka::MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, max_in_flight_requests_per_connection.to_s)  unless max_in_flight_requests_per_connection.nil?
  props.put(kafka::ENABLE_IDEMPOTENCE_CONFIG, enable_idempotence.to_s) unless enable_idempotence.nil?

docker pull cclient/logstash:6.8.13
docker pull cclient/logstash:6.3.0