This is an automated email from the ASF dual-hosted git repository.
mittal pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from d5d9892413d KAFKA-19779: Add per-partition epoch validation to streams
groups [4/N] (#20760)
add bd8ea36a116 KAFKA-19846: Remove uuid to string conversion and
vice-versa for memberId on broker (#20819)
No new revisions were added by this update.
Summary of changes:
.../common/requests/ShareRequestMetadata.java | 7 -
.../java/kafka/server/share/SharePartition.java | 2 +-
.../kafka/server/share/SharePartitionManager.java | 66 +--
core/src/main/scala/kafka/server/KafkaApis.scala | 37 +-
.../server/share/SharePartitionManagerTest.java | 327 +++++++------
.../kafka/api/AuthorizerIntegrationTest.scala | 1 +
.../scala/unit/kafka/server/KafkaApisTest.scala | 508 +++++++++++++++++----
.../kafka/server/share/ShareGroupListener.java | 4 +-
.../kafka/server/share/context/FinalContext.java | 3 +-
.../server/share/context/ShareFetchContext.java | 3 +-
.../server/share/context/ShareSessionContext.java | 23 +-
.../kafka/server/share/fetch/InFlightState.java | 3 +-
.../server/share/session/ShareSessionCache.java | 3 +-
.../server/share/session/ShareSessionKey.java | 4 +-
.../share/session/ShareSessionCacheTest.java | 45 +-
.../server/share/session/ShareSessionKeyTest.java | 2 +-
16 files changed, 673 insertions(+), 365 deletions(-)
