Java Kafka 生产者：发送消息并获取回调结果

Java Kafka 生产者：发送消息并获取回调结果

本文介绍了在 Java 中使用 Kafka 生产者发送消息并获取回调结果的方法。

方法名称：sendAndReceiveCallbackResultToKafka

该方法用于发送消息并获取 Kafka 的回调结果内容。

代码示例：

import org.apache.kafka.clients.producer.Callback;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;
import org.apache.kafka.common.errors.SerializationException;

public class KafkaProducerExample {

    public void sendAndReceiveCallbackResultToKafka(String topic, String message) {
        // 创建 Kafka 生产者
        // ...

        // 创建回调函数
        Callback callback = (metadata, exception) -> {
            if (exception != null) {
                // 处理异常
                System.err.println('Error while producing message: ' + exception.getMessage());
            } else {
                // 获取回调结果内容
                System.out.println('Message sent successfully: ' + metadata.topic() + ' - ' + metadata.partition() + ' - ' + metadata.offset());
            }
        };

        // 创建消息记录
        ProducerRecord<String, String> record = new ProducerRecord<>(topic, message);

        // 发送消息并获取回调结果
        producer.send(record, callback);

        // ...
    }
}

说明：

1. sendAndReceiveCallbackResultToKafka 方法接受两个参数：主题 topic 和消息 message。
2. 该方法创建了一个回调函数，用于处理发送消息后的回调结果。
3. 回调函数接收两个参数：metadata 和 exception。
4. 如果发送消息失败，则 exception 不为空，可以处理异常。
5. 如果发送消息成功，则 metadata 对象包含回调结果内容，包括主题、分区和偏移量等信息。
6. send 方法将消息发送到 Kafka 服务器，并返回一个 Future 对象，可以通过 get 方法获取发送结果。
7. 使用回调函数可以异步获取发送结果，避免阻塞主线程。

总结：

通过上述代码示例，可以实现使用 Java Kafka 生产者发送消息并获取回调结果内容。回调函数可以方便地处理发送结果，例如记录日志、更新状态等。