ableegoldman commented on code in PR #16201:
URL: https://github.com/apache/kafka/pull/16201#discussion_r1628526527
##########
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java:
##########
@@ -53,6 +55,76 @@ public final class TaskAssignmentUtils {
private TaskAssignmentUtils() {}
+ /**
+ * Return an {@code AssignmentError} for a task assignment created for an
application.
+ *
+ * @param applicationState The application for which this task assignment
is being assessed.
+ * @param taskAssignment The task assignment that will be validated.
+ *
+ * @return {@code AssignmentError.NONE} if the assignment created for this
application is valid,
+ * or another {@code AssignmentError} otherwise.
+ */
+ public static AssignmentError validateTaskAssignment(final
ApplicationState applicationState,
Review Comment:
just to save myself some review time: was anything changed here or is it
just a copy-paste from SPA to 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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
