Kafka plugin for FluQ