From 0e384ee45a30d5747308edf643c980078cf781c4 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Thu, 13 Feb 2025 19:56:01 +0100 Subject: [PATCH] Die Filter-Strategie muss nicht explizit gesetzt werden --- src/main/java/de/juplo/kafka/ExampleConsumer.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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()); -- 2.20.1