module CoreExtensions::Kafka::Broker