This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from d3707fc815c KAFKA-19214: Clean up use of Optionals in
RequestManagers.entries() (#19609)
add 67b46fec15c MINOR: introduce structure to keep member assignment with
topic Ids (#19645)
No new revisions were added by this update.
Summary of changes:
.../internals/AbstractMembershipManager.java | 60 +++-----
.../consumer/internals/TopicIdPartitionSet.java | 114 +++++++++++++++
.../internals/TopicIdPartitionSetTest.java | 154 +++++++++++++++++++++
3 files changed, 291 insertions(+), 37 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicIdPartitionSet.java
create mode 100644
clients/src/test/java/org/apache/kafka/clients/consumer/internals/TopicIdPartitionSetTest.java
