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

在 Java 中使用 Kafka 生产者发送消息并获取回调结果，可以使用 sendAndReceiveCallback() 方法。该方法可以简化代码，提高可读性。

示例：

public class KafkaProducerExample {

    public void sendAndReceiveCallback(String topic, String message) {
        // 创建 Kafka 生产者
        Producer<String, String> producer = new KafkaProducer<>(properties);

        // 发送消息
        ProducerRecord<String, String> record = new ProducerRecord<>(topic, message);
        producer.send(record, (metadata, exception) -> {
            if (exception != null) {
                // 处理异常
            } else {
                // 获取回调结果
                System.out.println("消息已发送：" + metadata.toString());
            }
        });

        // 关闭生产者
        producer.close();
    }
}

注意：

• 该示例代码仅供参考，实际应用中可能需要根据具体情况进行调整。
• 回调结果可以通过 metadata 对象获取。
• 可以根据需要对回调结果进行处理。