module CoreExtensions::Kafka::Client