ableegoldman commented on a change in pull request #8596:
URL: https://github.com/apache/kafka/pull/8596#discussion_r419711999
##########
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##########
@@ -877,7 +877,7 @@
public static final String
STREAMS_METADATA_STATE_FOR_PARTITION_ASSIGNOR =
"__streams.metadata.state.instance__";
public static final String STREAMS_ADMIN_CLIENT =
"__streams.admin.client.instance__";
public static final String ASSIGNMENT_ERROR_CODE =
"__assignment.error.code__";
- public static final String NEXT_PROBING_REBALANCE_MS =
"__next.probing.rebalance.ms__";
+ public static final String NEXT_SCHEDULED_REBALANCE_MS =
"__next.probing.rebalance.ms__";
Review comment:
Are you asking if this change was intentional, or are you referring to a
different config key? If the former, note that this internal config was only
added a few PRs ago so there would be no compatibility concerns even if it
wasn't confined to a single instance
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
