Использование BaseConsumerRecord (устарело) в MirrorMakerMessageHandler?

Question

Существует ли более новый или рекомендуемый способ написания MirrorMakerMessageHandler, поскольку BaseConsumerRecord помечен как устаревший?

public class CustomHandler implements kafka.tools.MirrorMaker.MirrorMakerMessageHandler {

    @Override
    public java.util.List<org.apache.kafka.clients.producer.ProducerRecord<byte[], byte[]>> handle(kafka.consumer.BaseConsumerRecord arg0) {

        return null;
    }

}

Answer 1

Вы реализуете интерфейс , поэтому нет обходного пути до изменения API или написания нового способа зеркального отображения тем (KIP-382)