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(-)

Reply via email to