From b9ecdd6cccf5c675af054b0cfefb55ef9ecaaacb Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 12 Apr 2025 23:58:52 +0200 Subject: [PATCH] Tippfehler in Konfig-Parameter korrigiert --- src/main/java/de/juplo/kafka/ApplicationConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java index d389e76..ea6b64e 100644 --- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java @@ -44,7 +44,7 @@ public class ApplicationConfiguration { props.put("auto.commit.interval", properties.getConsumerProperties().getAutoCommitInterval()); } - props.put("metadata.maxage.ms", 5000); // 5 Sekunden + props.put("metadata.max.age.ms", 5000); // 5 Sekunden props.put("key.deserializer", StringDeserializer.class.getName()); props.put("value.deserializer", StringDeserializer.class.getName()); -- 2.20.1