由于baseconsumerrecord被标记为已弃用，是否有更新或推荐的方法来编写mirrormakermessagehandler？

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;
    }

}