[streaming] Added Kafka iterator