Real-Time Integration and Streaming Analytics for Kafka