From 736de882af5682c2ee1edb06750f8bb79343c074 Mon Sep 17 00:00:00 2001 From: GurtejSohi Date: Thu, 8 Oct 2020 18:15:35 +0530 Subject: [PATCH] Add logging info when building kafka sub topology (#11) --- .../java/org/hypertrace/ingester/HypertraceIngester.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/hypertrace-ingester/src/main/java/org/hypertrace/ingester/HypertraceIngester.java b/hypertrace-ingester/src/main/java/org/hypertrace/ingester/HypertraceIngester.java index 30f61de7c..0e6613eff 100644 --- a/hypertrace-ingester/src/main/java/org/hypertrace/ingester/HypertraceIngester.java +++ b/hypertrace-ingester/src/main/java/org/hypertrace/ingester/HypertraceIngester.java @@ -18,12 +18,16 @@ import org.hypertrace.core.spannormalizer.SpanNormalizer; import org.hypertrace.core.viewgenerator.service.MultiViewGeneratorLauncher; import org.hypertrace.traceenricher.trace.enricher.TraceEnricher; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * Hypertrace ingestion pipeline */ public class HypertraceIngester extends KafkaStreamsApp { + private static final Logger LOGGER = LoggerFactory.getLogger(HypertraceIngester.class); + private static final String HYPERTRACE_INGESTER_JOB_CONFIG = "hypertrace-ingester-job-config"; private Map> jobNameToSubTopology = new HashMap<>(); @@ -61,6 +65,8 @@ public StreamsBuilder buildTopology(Map properties, List subTopologiesNames = getSubTopologiesNames(properties); for (String subTopologyName : subTopologiesNames) { + LOGGER.info("Building sub topology :{}", subTopologyName); + // create an instance and retains is reference to be used later in other methods KafkaStreamsApp subTopology = getSubTopologyInstance(subTopologyName); jobNameToSubTopology