Skip to content

Commit

Permalink
Add logging info when building kafka sub topology (#11)
Browse files Browse the repository at this point in the history
  • Loading branch information
GurtejSohi authored Oct 8, 2020
1 parent a45a778 commit 736de88
Showing 1 changed file with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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<String, Pair<String, KafkaStreamsApp>> jobNameToSubTopology = new HashMap<>();
Expand Down Expand Up @@ -61,6 +65,8 @@ public StreamsBuilder buildTopology(Map<String, Object> properties,
List<String> 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
Expand Down

0 comments on commit 736de88

Please sign in to comment.