From 0e384ee45a30d5747308edf643c980078cf781c4 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
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 2efce13..7dec6be 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