KafkaCommit：生产者与消费者

Kafka中的消息传递是异步的，因此，其中非常重要的一个问题是如何确认消息是否被成功处理。为此，Kafka有两个重要概念：消息确认和偏移量。消息确认是指向生产者返回的确定消息已被成功写入Kafka主题的信号；偏移量则是指消息在主题分区中的位置。

对于生产者而言，Kafka提供了两个常用的消息确认机制：同步发送和异步发送。对于同步发送，即send()方法将等待生产者接收到服务器确认消息后才会返回。而对于异步发送，sender将在消息发送之后立即返回，而不是等待服务器返回确认信息。

而对于消费者而言，Kafka有两种重要的消息确认机制：自动提交和手动提交。自动提交是指消费者在配置中定义了一个确定提交时间的时间间隔，Kafka会定期地将消费者的偏移量提交到Kafka服务器。而手动提交则需要消费者明确地调用commitSync()或commitAsync()方法将偏移量提交到服务器。手动提交的优点是允许消费者控制何时提交偏移量，而缺点是容易在处理消息时发生故障，因为偏移量并没有即时提交，可能无法处理或重复处理消息。

下面是手动提交偏移量的示例代码：

while (true) {
   ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
   for (ConsumerRecord<String, String> record : records) {
           processRecord(record);
   }
   consumer.commitAsync();//异步提交偏移量
}

需要注意的是，需要在循环的外部实现一个shutdown hook，以便在程序退出时关闭消费者并提交偏移量。例如：

Runtime.getRuntime().addShutdownHook(new Thread() {
   public void run() {
       consumer.close();
       try {
           consumer.commitSync();
       } catch (Exception e) {
           log.error("Error committing offset");
       }
   }
});