Scalable Data Management for Kafka and Beyond