Skip to content

Commit ef18021

Browse files
authored
log kafka topology before start (#40)
1 parent ed495da commit ef18021

File tree

1 file changed

+2
-0
lines changed
  • kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework

1 file changed

+2
-0
lines changed

kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/KafkaStreamsApp.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,8 @@ protected void doInit() {
112112
System.exit(1);
113113
}
114114
);
115+
116+
getLogger().info("kafka streams topologies: {}", topology.describe());
115117
} catch (Exception e) {
116118
getLogger().error("Error initializing - ", e);
117119
e.printStackTrace();

0 commit comments

Comments
 (0)