We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0fb5853 commit 412decfCopy full SHA for 412decf
streams-bootstrap-core/src/main/java/com/bakdata/kafka/streams/StreamsConfigX.java
@@ -91,6 +91,11 @@ public List<String> getBoostrapServers() {
91
return this.getList(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG);
92
}
93
94
+ /**
95
+ * Check if adding lineage headers is enabled. This is controlled by {@link #LINEAGE_ENABLED_CONFIG}
96
+ *
97
+ * @return true if lineage headers are added to streams and tables
98
+ */
99
public boolean isLineageEnabled() {
100
return this.getBoolean(LINEAGE_ENABLED_CONFIG);
101
0 commit comments