You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by da...@apache.org on 2023/09/01 10:45:31 UTC

[kafka] branch trunk updated (d0f3cf1f9fa -> dcff0878c48)

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

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


    from d0f3cf1f9fa KAFKA-15351: Ensure log-start-offset not updated to local-log-start-offset when remote storage enabled (#14301)
     add dcff0878c48 KAFKA-14499: [5/N] Refactor GroupCoordinator.fetchOffsets and GroupCoordinator.fetchAllOffsets (#14310)

No new revisions were added by this update.

Summary of changes:
 .../group/GroupCoordinatorAdapter.scala            | 23 +++----
 core/src/main/scala/kafka/server/KafkaApis.scala   | 49 +++++++--------
 .../group/GroupCoordinatorAdapterTest.scala        | 26 ++++----
 .../scala/unit/kafka/server/KafkaApisTest.scala    | 73 ++++++++++++----------
 .../kafka/coordinator/group/GroupCoordinator.java  | 14 ++---
 .../coordinator/group/GroupCoordinatorService.java | 33 +++++-----
 .../coordinator/group/GroupCoordinatorShard.java   | 19 +++---
 .../coordinator/group/OffsetMetadataManager.java   | 38 ++++++-----
 .../group/GroupCoordinatorServiceTest.java         | 66 ++++++++++---------
 .../group/OffsetMetadataManagerTest.java           | 15 +++--
 10 files changed, 189 insertions(+), 167 deletions(-)