diff --git a/litmus-core/src/main/java/com/navi/medici/listener/ExperimentMetricResultListener.java b/litmus-core/src/main/java/com/navi/medici/listener/ExperimentMetricResultListener.java index 09d8213..e6c4be4 100644 --- a/litmus-core/src/main/java/com/navi/medici/listener/ExperimentMetricResultListener.java +++ b/litmus-core/src/main/java/com/navi/medici/listener/ExperimentMetricResultListener.java @@ -5,7 +5,6 @@ import com.navi.medici.service.experimentmetricresult.ExperimentMetricResultServ import io.micrometer.core.instrument.MeterRegistry; import lombok.RequiredArgsConstructor; import lombok.extern.log4j.Log4j2; -import org.springframework.kafka.annotation.KafkaListener; import org.springframework.kafka.support.KafkaHeaders; import org.springframework.messaging.handler.annotation.Header; import org.springframework.messaging.handler.annotation.Payload; @@ -19,7 +18,7 @@ public class ExperimentMetricResultListener { private final ExperimentMetricResultService experimentMetricResultService; private final MeterRegistry meterRegistry; - @KafkaListener(topics = "${kafka.experiment.metric.result.topic}", groupId = "${kafka.litmus.consumer.group}") + // @KafkaListener(topics = "${kafka.experiment.metric.result.topic}", groupId = "${kafka.litmus.consumer.group}") public void listenMetricResultFromTesseract(@Header(value = KafkaHeaders.CORRELATION_ID, required = false) String correlationId, @Header(value = "job_run_id", required = false) String jobRunId, @Header(value = "tesseract_id", required = false) String tesseractId,