From d0d1148be280c5bf861c154346a24632d635dcf6 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 16 Sep 2022 19:25:03 +0200 Subject: [PATCH] WIP --- src/main/java/de/juplo/kafka/Application.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/main/java/de/juplo/kafka/Application.java b/src/main/java/de/juplo/kafka/Application.java index 69a9712..d913823 100644 --- a/src/main/java/de/juplo/kafka/Application.java +++ b/src/main/java/de/juplo/kafka/Application.java @@ -1,6 +1,7 @@ package de.juplo.kafka; import lombok.extern.slf4j.Slf4j; +import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.common.serialization.ByteArraySerializer; import org.apache.kafka.common.serialization.StringSerializer; import org.springframework.boot.SpringApplication; @@ -53,12 +54,14 @@ public class Application ApplicationRecordHandler recordHandler, AdderResults adderResults, StateRepository stateRepository, + Consumer kafkaConsumer, KafkaProperties kafkaProperties) { return new ApplicationRebalanceListener( recordHandler, adderResults, stateRepository, + kafkaConsumer, kafkaProperties.getConsumer().getGroupId()); } -- 2.20.1