Kafka Integration for Logstash, providing Input and Output Plugins - View it on GitHub