在卡夫卡中批量消费时如何部分提交同步

我们正在与卡夫卡合作。我们使用X条消息,将它们放到MYSQL上,然后提交它们。

有时我们会部分插入MYSQL(重复记录、其他故障等)

使用文档中的示例:

List<ConsumerRecord<String, String>> buffer = new ArrayList<>();
    while (true) {
        ConsumerRecords<String, String> records = consumer.poll(100);
        for (ConsumerRecord<String, String> record : records) {
            buffer.add(record);
        }
        if (buffer.size() >= minBatchSize) {
            insertIntoDb(buffer);
            consumer.commitSync();
            buffer.clear();
        }

我们只想提交成功的记录,而让卡夫卡重播失败的记录。

但我不明白该怎么做,因为api在整个批处理中只有commitSync()。

思想?