This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from d27d90ccb3b MINOR: Refactor OffsetFetch path (#21009)
     add a9cc8f21e25 MINOR: Move ShareAcquireMode to consumer.internal package 
(#20973)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/consumer/ConsumerConfig.java     |   1 +
 .../consumer/{ => internals}/ShareAcquireMode.java |   9 +-
 .../internals/ShareConsumeRequestManager.java      |   1 -
 .../consumer/internals/ShareFetchConfig.java       |   1 -
 .../kafka/common/requests/ShareFetchRequest.java   |   2 +-
 ...mentModeTest.java => ShareAcquireModeTest.java} |  44 +++----
 .../internals/ShareConsumeRequestManagerTest.java  |   1 -
 .../internals/ShareSessionHandlerTest.java         |   1 -
 .../java/kafka/server/share/SharePartition.java    |   4 +-
 .../kafka/server/share/DelayedShareFetchTest.java  |   2 +-
 .../kafka/server/share/ShareFetchUtilsTest.java    |   2 +-
 .../server/share/SharePartitionManagerTest.java    |   2 +-
 .../kafka/server/share/SharePartitionTest.java     | 143 ++++++++++++++++++---
 .../kafka/api/AuthorizerIntegrationTest.scala      |   2 +-
 .../unit/kafka/server/ReplicaManagerTest.scala     |   2 +-
 .../server/ShareFetchAcknowledgeRequestTest.scala  |   2 +-
 .../kafka/server/share/fetch/ShareFetch.java       |   2 +-
 .../kafka/server/share/fetch/ShareFetchTest.java   |   2 +-
 18 files changed, 160 insertions(+), 63 deletions(-)
 rename clients/src/main/java/org/apache/kafka/clients/consumer/{ => 
internals}/ShareAcquireMode.java (93%)
 copy 
clients/src/test/java/org/apache/kafka/clients/consumer/internals/{ShareAcknowledgementModeTest.java
 => ShareAcquireModeTest.java} (54%)

Reply via email to