我有一个SpringBootKafka消费者，它使用一个主题中的数据并将其存储在数据库中，一旦存储就确认它。它工作正常，但如果应用程序在使用记录后未能获得db连接，则会出现问题，在这种情况下，我们不会发送确认，但在更改组id并重新启动使用程序之前，或除非更改组id并重新启动使用器，否则消息仍然不会被使用
我的消费者如下所示

@KafkaListener(id = "${group.id}", topics = {"${kafka.edi.topic}"})
  public void onMessage(ConsumerRecord record, Acknowledgment acknowledgment) {
      boolean shouldAcknowledge = false;
      try {
          String tNo = getTrackingNumber((String) record.key());

          log.info("Check Duplicate By Comparing With DB records");

          if (!ediRecordService.isDuplicate(tNo)) {---this checks the record in my DB
              shouldAcknowledge = insertEDIRecord(record, tNo); --this return true
          } else {
              log.warn("Duplicate record found.");
              shouldAcknowledge = true;
          }
          if (shouldAcknowledge) {
              acknowledgment.acknowledge();
          }```

So if you see the above snippet we did not sent acknowledgment.