java - 如何回滚 kafka 消费者轮询

Question

卡夫卡 2.2.0。在我看来，消费者总是提交并忽略配置

// Configuration
props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, 0);
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

// read data
records = consumer.poll(Duration.ofMinutes(1));
// do some processing on records
// throw an exception and exit
// restart the application (actually I'm debugging under idea)

由于异常，我希望下一次调用 consumer.poll() 获得与我没有调用 consumer.commitSync() 相同的数据。

标签： javaapache-kafkakafka-consumer-api