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 4f28973bd19 KAFKA-18827: Initialize share state, share coordinator
impl. [1/N] (#18968)
add 6e45ab7d844 KAFKA-17351: Update tests and acquire API to allow discard
batches from compacted topics (1/N) (#18978)
No new revisions were added by this update.
Summary of changes:
.../java/kafka/server/share/DelayedShareFetch.java | 26 +-
.../java/kafka/server/share/ShareFetchUtils.java | 21 +-
.../java/kafka/server/share/SharePartition.java | 2 +
.../kafka/server/share/DelayedShareFetchTest.java | 26 +-
.../kafka/server/share/ShareFetchUtilsTest.java | 106 +-
.../server/share/SharePartitionManagerTest.java | 15 +-
.../kafka/server/share/SharePartitionTest.java | 1276 +++++---------------
...eFetchKey.java => ShareFetchPartitionData.java} | 12 +-
8 files changed, 422 insertions(+), 1062 deletions(-)
copy
server/src/main/java/org/apache/kafka/server/share/fetch/{DelayedShareFetchKey.java
=> ShareFetchPartitionData.java} (70%)
