kafka批量提交offset配置

你可以使用 Kafka 消费者 API 中的 `enable.auto.commit` 和 `auto.commit.interval.ms` 属性来配置批量提交 offset。具体配置如下：

properties.put("enable.auto.commit", "false"); // 禁止自动提交 offset
properties.put("auto.commit.interval.ms", "1000"); // 设置批量提交 offset 的时间间隔，单位为毫秒

然后在消费者代码中使用 `commitSync()` 方法来手动提交 offset，例如：

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

这样就可以控制 offset 的提交时间，避免频繁提交造成的性能问题。

相关问题

spring boot kafka配置文件详解

当我们使用 Spring Boot 搭建 Kafka 生产者和消费者时，需要在配置文件中进行相关配置。下面是一个简单的 Kafka 配置文件示例：

# Kafka 集群地址
spring.kafka.bootstrap-servers=127.0.0.1:9092

# 消费者组 ID
spring.kafka.consumer.group-id=my-group

# 生产者配置
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

上述配置文件中，我们指定了 Kafka 集群地址、消费者组 ID 和生产者的 key 和 value 序列化方式。

其中，`spring.kafka.bootstrap-servers` 用于指定 Kafka 集群的地址，可以指定多个地址以逗号分隔。

`spring.kafka.consumer.group-id` 用于指定消费者组的 ID。

`spring.kafka.producer.key-serializer` 和 `spring.kafka.producer.value-serializer` 用于指定生产者发送消息时序列化 key 和 value 的方式，这里我们使用了字符串序列化器。

除此之外，还有其他可用的配置项，比如消费者的 offset 自动提交方式、消息的最大和最小批量大小等，具体可以参考官方文档。