精准一次消费kafka有几种方式？分别举例实现方式

精准一次消费 Kafka 有两种方式：

1. 事务机制

事务机制是 Kafka 提供的一个可靠的消息传递方式，它保证了消息的完整性和一致性。通过事务机制，可以实现精准一次消费。

举例实现方式：

producer.beginTransaction();
try {
    producer.send(record1);
    producer.send(record2);
    producer.send(record3);
    producer.commitTransaction();
} catch (Exception e) {
    producer.abortTransaction();
}

2. 手动提交偏移量

手动提交偏移量是将消息消费后，手动提交偏移量，保证消费者不会重复消费消息，从而实现精准一次消费。

举例实现方式：

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    for (ConsumerRecord<String, String> record : records) {
        // 处理消息
    }
    consumer.commitAsync(); // 手动提交偏移量
}