From 05c78a1cf1a3af27b01827e48784b7913c45fc27 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 2 Aug 2022 21:04:16 +0200 Subject: [PATCH] Asciidoc-Tags entfernt --- src/main/java/de/juplo/kafka/SimpleConsumer.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java index 03a9e6a..ef8d7e3 100644 --- a/src/main/java/de/juplo/kafka/SimpleConsumer.java +++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java @@ -46,14 +46,11 @@ public class SimpleConsumer log.info("{} - Subscribing to topic test", id); consumer.subscribe(Arrays.asList("test")); - // tag::loop[] while (running) { ConsumerRecords records = consumer.poll(Duration.ofSeconds(1)); - // Do something with the data... - // end::loop[] log.info("{} - Received {} messages", id, records.count()); for (ConsumerRecord record : records) { @@ -68,9 +65,7 @@ public class SimpleConsumer record.value() ); } - // tag::loop[] } - // end::loop[] } catch(Exception e) { -- 2.20.1