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 f9b4cdbbc9f KAFKA-18485; Update log4j2.yaml (#18504)
add 4e24c50ba3e KAFKA-18404: Remove partitionMaxBytes usage from
DelayedShareFetch (#17870)
No new revisions were added by this update.
Summary of changes:
.../java/kafka/server/share/DelayedShareFetch.java | 108 ++++---
.../kafka/server/share/DelayedShareFetchTest.java | 357 ++++++++++++++++++++-
.../server/share/SharePartitionManagerTest.java | 3 +
.../java/kafka/test/api/ShareConsumerTest.java | 2 +-
.../server/ShareFetchAcknowledgeRequestTest.scala | 14 +-
.../share/fetch/PartitionMaxBytesStrategy.java | 77 +++++
.../share/fetch/PartitionMaxBytesStrategyTest.java | 90 ++++++
7 files changed, 596 insertions(+), 55 deletions(-)
create mode 100644
share/src/main/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategy.java
create mode 100644
share/src/test/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategyTest.java
