class KafkaCommand::Engine