fix cross cluster operations for real this time

patschuh · Oct 19, 2023 · 506901b · 506901b
1 parent 0b12405
commit 506901b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/build.gradle b/build.gradle
@@ -73,7 +73,7 @@ java {
 }
 
 javafx {
-    version = '17'
+    version = '21'
     modules = ['javafx.controls', 'javafx.fxml']
 }
 

diff --git a/src/main/java/at/esque/kafka/CrossClusterController.java b/src/main/java/at/esque/kafka/CrossClusterController.java
@@ -45,6 +45,7 @@
 import java.text.MessageFormat;
 import java.time.Duration;
 import java.time.Instant;
+import java.util.Iterator;
 import java.util.List;
 import java.util.Optional;
 import java.util.UUID;
@@ -193,8 +194,9 @@ private void startOperation(UUID operationId) {
                 while (!operation.getStop().get() && (limit == null || count.get() < limit) && !operation.getStatus().equals("Error")) {
                     ConsumerRecords consumerRecords = kafkaConsumer.poll(Duration.ofSeconds(5));
                     Iterable<ConsumerRecord> records = consumerRecords.records(operation.getFromTopic().getName());
-                    while ((limit == null || count.get() < limit) && records.iterator().hasNext()) {
-                        ConsumerRecord consumerRecord = records.iterator().next();
+                    Iterator<ConsumerRecord> iterator = records.iterator();
+                    while ((limit == null || count.get() < limit) && iterator.hasNext()) {
+                        ConsumerRecord consumerRecord = iterator.next();
                         try {
                             if (operation.getFilterFunction().test(consumerRecord)) {
                                 if (reserializeMessagesToggle.isSelected()) {