KAFKA中发布新事件后在最大轮询间隔之前跳过滞后偏移量。

在KAFKA的consumer配置中，可以设置参数enable.auto.commit=false，然后手动提交offset。在消费者处理完消息后，手动提交offset，这样可以保证消费完整个分区中的消息后再提交offset，避免出现跳跃式的偏移量。

示例代码：

//定义参数 Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("group.id", "test"); props.put("enable.auto.commit", "false"); //手动提交offset props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

//创建consumer KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

//订阅主题 consumer.subscribe(Arrays.asList("test-topic"));

//拉取消息 while (true) { ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100)); for (ConsumerRecord<String, String> record : records) { //处理消息 System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value()); } //手动提交offset consumer.commitSync(); }