From: Kai Moritz <kai@juplo.de>
Date: Thu, 13 Feb 2025 18:56:01 +0000 (+0100)
Subject: Die Filter-Strategie muss nicht explizit gesetzt werden
X-Git-Tag: spring/spring-consumer--messageconverter--2025-03-signal~1
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=0e384ee45a30d5747308edf643c980078cf781c4;p=demos%2Fkafka%2Ftraining

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 2efce13c..7dec6be8 100644
--- 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());