Kafka dataflow test