Kafka firehose 0.8