Kafka Messaging Controller API.