Configuring "consumer_threads" for a Kafka input with multiple Logstash instances

Answered here