Kafka Extended API (TBD)