module CoreExtensions::Kafka::Protocol