This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from f3da8f500eb KAFKA-18936: Fix share fetch when records are larger than
max bytes (#19145)
add c07c59ad24b KAFKA-18932: Removed usage of partition max bytes from
share fetch requests (#19148)
No new revisions were added by this update.
Summary of changes:
.../consumer/internals/ShareSessionHandler.java | 2 +-
.../kafka/common/requests/ShareFetchRequest.java | 60 +-
.../common/message/ShareFetchRequest.json | 2 -
.../java/kafka/server/share/DelayedShareFetch.java | 2 +-
.../kafka/server/share/SharePartitionManager.java | 42 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 18 +-
.../kafka/server/share/DelayedShareFetchTest.java | 83 ++-
.../kafka/server/share/ShareFetchUtilsTest.java | 19 +-
.../server/share/SharePartitionManagerTest.java | 309 +++++------
.../scala/unit/kafka/server/KafkaApisTest.scala | 605 +++++++++------------
.../unit/kafka/server/ReplicaManagerTest.scala | 7 +-
.../server/ShareFetchAcknowledgeRequestTest.scala | 175 ++----
.../kafka/server/share/CachedSharePartition.java | 22 +-
.../share/ErroneousAndValidPartitionData.java | 21 +-
.../server/share/context/ShareSessionContext.java | 14 +-
.../share/fetch/PartitionRotateStrategy.java | 30 +-
.../kafka/server/share/fetch/ShareFetch.java | 16 +-
.../kafka/server/share/session/ShareSession.java | 17 +-
.../share/fetch/PartitionRotateStrategyTest.java | 37 +-
.../kafka/server/share/fetch/ShareFetchTest.java | 17 +-
.../server/share/fetch/ShareFetchTestUtils.java | 45 +-
21 files changed, 581 insertions(+), 962 deletions(-)
