ableegoldman opened a new pull request #9446: URL: https://github.com/apache/kafka/pull/9446
Minor followup to KAFKA-10559 I noticed that we were converting any and all TaskAssignmentException to the INCOMPLETE_SOURCE_TOPIC_METADATA error code to shut down all the clients. Since these errors are typically fatal, it does seem appropriate to propagate the shutdown command. But we should do so with a new AssignorError instead of piggy-backing on the INCOMPLETE_SOURCE_TOPIC_METADATA, which would be pretty confusing for users who do in fact have all their source topics. Changes in this PR: - Add new AssignorError.ASSIGNMENT_ERROR for generic assignment errors - Missing source topics --> throw/catch MissingSourceTopicException --> INCOMPLETE_SOURCE_TOPIC_METADATA - Internal assignment errors --> throw/catch TaskAssignmentException --> ASSIGNMENT_ERROR Should be cherry-picked to 2.7 ---------------------------------------------------------------- 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
