mjsax commented on a change in pull request #9384:
URL: https://github.com/apache/kafka/pull/9384#discussion_r504910261
##########
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##########
@@ -900,9 +900,7 @@
// These are not settable in the main Streams config; they are set by
the StreamThread to pass internal
// state into the assignor.
- public static final String TASK_MANAGER_FOR_PARTITION_ASSIGNOR =
"__task.manager.instance__";
- 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 REFERENCE_CONTAINER_PARTITION_ASSIGNOR =
"__reference.container.instance__";
public static final String ASSIGNMENT_ERROR_CODE =
"__assignment.error.code__";
public static final String NEXT_SCHEDULED_REBALANCE_MS =
"__next.probing.rebalance.ms__";
public static final String TIME = "__time__";
Review comment:
Ah. Ack.
Actually, we can also pull `INTERNAL_TASK_ASSIGNOR_CLASS` and
`ASSIGNMENT_LISTENER` into the reference container.
----------------------------------------------------------------
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
