This is an automated email from the ASF dual-hosted git repository. junrao pushed a change to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git
from d3b4c1bdf41 KAFKA-18401: Transaction version 2 does not support commit transaction without records (#18448) add 06400177bb3 KAFKA-18452: Implemented batch size in acquired records (#18459) No new revisions were added by this update. Summary of changes: .../java/kafka/server/share/ShareFetchUtils.java | 2 +- .../java/kafka/server/share/SharePartition.java | 93 +++- .../kafka/server/share/SharePartitionManager.java | 4 +- core/src/main/scala/kafka/server/KafkaApis.scala | 1 + .../kafka/server/share/DelayedShareFetchTest.java | 61 ++- .../kafka/server/share/ShareFetchUtilsTest.java | 35 +- .../server/share/SharePartitionManagerTest.java | 133 +++-- .../kafka/server/share/SharePartitionTest.java | 604 +++++++++++++++------ .../scala/unit/kafka/server/KafkaApisTest.scala | 32 +- .../kafka/server/share/fetch/ShareFetch.java | 10 + .../kafka/server/share/fetch/ShareFetchTest.java | 7 +- 11 files changed, 660 insertions(+), 322 deletions(-)