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 c5ae7b41281 KAFKA-18794: Add check to send one ShareFetchEvent per
poll in ShareConsumer. (#20794)
add b900f2fe5a0 KAFKA-19797: Added deliveryCompleteCount to writeState,
ShareUpdate and ShareSnapshot schemas (#20810)
No new revisions were added by this update.
Summary of changes:
.../message/WriteShareGroupStateRequest.json | 7 +-
.../message/WriteShareGroupStateResponse.json | 5 +-
.../kafka/common/requests/RequestResponseTest.java | 1 +
.../java/kafka/server/share/SharePartition.java | 80 +--
.../kafka/server/share/SharePartitionTest.java | 626 ++++++++++-----------
.../scala/unit/kafka/server/KafkaApisTest.scala | 2 +
.../share/persister/DefaultStatePersister.java | 1 +
.../server/share/persister/PartitionData.java | 20 +-
.../server/share/persister/PartitionFactory.java | 17 +-
.../share/persister/PartitionStateBatchData.java | 2 +
.../share/persister/PersisterStateManager.java | 6 +
.../persister/WriteShareGroupStateParameters.java | 6 +-
.../share/persister/DefaultStatePersisterTest.java | 5 +-
.../share/persister/PersisterStateManagerTest.java | 7 +
.../share/ShareCoordinatorRecordHelpers.java | 2 +
.../coordinator/share/ShareCoordinatorService.java | 1 +
.../coordinator/share/ShareCoordinatorShard.java | 4 +
.../kafka/coordinator/share/ShareGroupOffset.java | 27 +-
.../common/message/ShareSnapshotValue.json | 3 +
.../resources/common/message/ShareUpdateValue.json | 3 +
.../share/ShareCoordinatorRecordHelpersTest.java | 4 +
.../share/ShareCoordinatorServiceTest.java | 5 +
.../share/ShareCoordinatorShardTest.java | 44 +-
23 files changed, 506 insertions(+), 372 deletions(-)
