module CoreExtensions::Kafka::Cluster