class MagicPipe::Transports::Kafka