removed infinity loop #9

Kasean · Dec 29, 2023 · 4567f0e · 4567f0e
1 parent d304ab9
commit 4567f0e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/archiver/src/main/java/org/student/messaging/MessageConsumer.java b/archiver/src/main/java/org/student/messaging/MessageConsumer.java
@@ -27,8 +27,8 @@ public MessageConsumer(String bootstrapServers, String groupId) {
     public void consume(String topic) {
         consumer.subscribe(Collections.singletonList(topic));
 
-        while (true) {
-            ConsumerRecords<String, byte[]> records = consumer.poll(Duration.ofMillis(100));
+        ConsumerRecords<String, byte[]> records = consumer.poll(Duration.ofMillis(1000));
+        if (!records.isEmpty()) {
             for (ConsumerRecord<String, byte[]> record : records) {
                 System.out.println("Consumed message: " + new String(record.value()));
             }