Add real Kafka streaming test