module CoreExtensions::Kafka