Kafka API

Generic abstractions for Kafka API.