Hi all, I am implementing a custom partition assignor slightly different than the sticky assignor assignor. As known, in the sticky assignor each consumer sends the set of owned partitions as part of its subscription message. This happens in the subscriptionUserData by calling the serializeTopicPartitionAssignment method etc…
Kindly, my question is that what is the most seamless way to get offset information (e.g., last committed offset) for each owned partition from within the subscriptionUserData method or generally from within the stickyAssignor class, preferably using public APIs. Thank you.
