Die Filter-Strategie muss nicht explizit gesetzt werden

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 2efce13..7dec6be 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -15,9 +15,7 @@ public class ExampleConsumer
   private long consumed = 0;
 
 
-  @KafkaListener(
-    topics = "${juplo.consumer.topic}",
-    filter = "addNumberRecordFilterStrategy")
+  @KafkaListener(topics = "${juplo.consumer.topic}")
   private void addNumber(MessageAddNumber addNumber)
   {
     log.info("{} - Adding number {}", id, addNumber.getNext());