class KafkaReplicator::Error