Stream processing using Kafka