KafkaInput and KafkaOutput plugins for Heka