refactor: use ConsumerRecords#nextOffsets in fixTxOffsets

Signed-off-by: Su Ko <rhtn1128@gmail.com>

Author: bandalgomsu

spring-kafka/src/main/java/org/springframework/kafka/listener/KafkaMessageListenerContainer.java

@@ -1630,7 +1630,7 @@ private void fixTxOffsetsIfNeeded() {
 				nextOffsets.forEach((tp, nextOffset) -> {
 					OffsetAndMetadata committed = this.lastCommits.get(tp);
 
-					if(committed == null) {
+					if (committed == null) {
 						this.logger.debug(() -> "No committed offset for " + tp + "; skipping TX offset fix.");
 						return;
 					}
@@ -1645,7 +1645,8 @@ private void fixTxOffsetsIfNeeded() {
 							String.format("Fixing TX offsets for %d partitions: %s", toFix.size(), toFix));
 					if (this.kafkaTxManager == null) {
 						commitOffsets(toFix);
-					} else {
+					}
+					else {
 						Objects.requireNonNull(this.transactionTemplate)
 								.executeWithoutResult(status -> doSendOffsets(getTxProducer(), toFix));
 					}