module CoreExtensions::Kafka::BrokerPool