You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by li...@apache.org on 2025/05/07 17:58:03 UTC
(kafka) branch trunk updated (d3707fc815c -> 67b46fec15c)
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