[streaming] Added Kafka-layer