Alexander-Aghili opened a new pull request, #14834: URL: https://github.com/apache/kafka/pull/14834
Implemented ConsumerGroupInstallAssignment API on the Client according to KIP-848. Still need to do server implementation (That will be a separate pull request). Also, need to get the proper apiKey for JSON (That is why it's still a WIP). Applied the same testing strategy from ConsumerGroupHeartbeat API, with proper edits to work with ConsumerGroupInstallAssignment API. I wasn't exactly sure how to implement the errorCounts method for the ConsumerGroupInstallAssignmentResponse class so I used the ConsumerGroupHeartbeatResponse approach. Also, INVALID_ASSIGNMENT didn't show up as an Error so I assumed INVALID_REPLICA_ASSIGNMENT was what was meant, but that assumption might be wrong. Note: I'm a new committer so please feel free to point out any lack of testing, documentation, or anything else I missed in detail. -- 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]
