You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by sh...@apache.org on 2022/12/01 06:26:15 UTC
[kafka] branch trunk updated (6663acff230 -> 81d98993ada)
This is an automated email from the ASF dual-hosted git repository.
showuon pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 6663acff230 KAFKA-13152: Add cache size metrics (#12778)
add 81d98993ada KAFKA-13715: add generationId field in subscription (#12748)
No new revisions were added by this update.
Summary of changes:
.../consumer/ConsumerPartitionAssignor.java | 21 +++-
.../consumer/CooperativeStickyAssignor.java | 5 +
.../kafka/clients/consumer/StickyAssignor.java | 2 +
.../consumer/internals/AbstractStickyAssignor.java | 7 +-
.../consumer/internals/ConsumerCoordinator.java | 3 +-
.../consumer/internals/ConsumerProtocol.java | 4 +-
.../common/message/ConsumerProtocolAssignment.json | 4 +-
.../message/ConsumerProtocolSubscription.json | 8 +-
.../consumer/CooperativeStickyAssignorTest.java | 106 ++++++++++++++--
.../kafka/clients/consumer/StickyAssignorTest.java | 111 ++++++++++++----
.../internals/AbstractStickyAssignorTest.java | 139 +++++++++++++--------
.../consumer/internals/ConsumerProtocolTest.java | 91 +++++++++-----
12 files changed, 370 insertions(+), 131 deletions(-)