编写kafka监听器

在编写Kafka监听器时，首先需要定义一个实现了ProducerListener接口的类。然后，在该类中实现onSend、onError和onSuccess等方法来处理生产者发送消息时的事件。在onSend方法中，你可以对消息进行修改或添加额外的信息，比如在value中加上时间戳。例如，可以在onSend方法中实现以下代码来为所有生产者发送的消息添加时间戳：

@Override
public ProducerRecord onSend(ProducerRecord record) {
    return new ProducerRecord(
        record.topic(),
        record.partition(),
        record.timestamp(),
        record.key(),
        System.currentTimeMillis() + "," + record.value().toString()
    );
}

这样，每次生产者发送消息时，都会经过该监听器的onSend方法进行处理，从而实现对消息的统一处理操作。