ableegoldman commented on a change in pull request #8596:
URL: https://github.com/apache/kafka/pull/8596#discussion_r419827086
##########
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:
Oh, duh, I overlooked that. Guess I was just going for eventual
consistency here
----------------------------------------------------------------
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:
us...@infra.apache.org
