lucliu1108 commented on code in PR #22639:
URL: https://github.com/apache/kafka/pull/22639#discussion_r3462109134
##########
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##########
@@ -902,6 +902,11 @@ public class StreamsConfig extends AbstractConfig {
"Whether to use the configured <code>" +
PROCESSING_EXCEPTION_HANDLER_CLASS_CONFIG + "</code> during global store/KTable
processing. " +
"Disabled by default. This config will be removed in Kafka
Streams 5.0, where global exception handling will be enabled by default";
+ public static final String TOPOLOGY_DESCRIPTION_PUSH_ENABLED_CONFIG =
"topology.description.push.enabled";
+ private static final String TOPOLOGY_DESCRIPTION_PUSH_ENABLED_DOC =
"Controls whether the Kafka Streams client sends topology descriptions to the
broker when requested. " +
+ "When set to false, the client will not prepare or push topology
descriptions. " +
+ "Enabled by default.";
Review Comment:
Added
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
