varnitgoyal95/litmus-be
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

TP-26660 | remove kafka listener

Browse Source
This commit is contained in:
akshat-sonic
2023-04-27 23:24:00 +05:30
parent 950dcb2999
commit 0c0027f843
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
litmus-core/src/main/java/com/navi/medici/listener/ExperimentMetricResultListener.java
View File

@@ -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,