You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2024/05/15 05:57:25 UTC
(kafka) branch trunk updated (eb5559a40e6 -> bf88013a281)
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 eb5559a40e6 KAFKA-16686 Wait for given offset in TopicBasedRemoteLogMetadataManagerTest (#15885)
add bf88013a281 MINOR: Rename `Record` to `CoordinatorRecord` (#15949)
No new revisions were added by this update.
Summary of changes:
.../src/main/scala/kafka/server/BrokerServer.scala | 9 +-
.../main/scala/kafka/tools/DumpLogSegments.scala | 4 +-
.../unit/kafka/tools/DumpLogSegmentsTest.scala | 7 +-
.../group/{Record.java => CoordinatorRecord.java} | 10 +-
...dHelpers.java => CoordinatorRecordHelpers.java} | 72 +-
...ecordSerde.java => CoordinatorRecordSerde.java} | 14 +-
.../org/apache/kafka/coordinator/group/Group.java | 2 +-
.../coordinator/group/GroupCoordinatorService.java | 18 +-
.../coordinator/group/GroupCoordinatorShard.java | 52 +-
.../coordinator/group/GroupMetadataManager.java | 130 ++--
.../coordinator/group/OffsetMetadataManager.java | 34 +-
.../coordinator/group/classic/ClassicGroup.java | 12 +-
.../coordinator/group/consumer/ConsumerGroup.java | 30 +-
.../group/consumer/TargetAssignmentBuilder.java | 14 +-
.../apache/kafka/coordinator/group/Assertions.java | 12 +-
...Test.java => CoordinatorRecordHelpersTest.java} | 82 +--
...deTest.java => CoordinatorRecordSerdeTest.java} | 36 +-
...{RecordTest.java => CoordinatorRecordTest.java} | 12 +-
.../group/GroupCoordinatorServiceTest.java | 120 ++--
.../group/GroupCoordinatorShardTest.java | 116 +--
.../group/GroupMetadataManagerTest.java | 782 ++++++++++-----------
.../group/GroupMetadataManagerTestContext.java | 66 +-
.../group/OffsetMetadataManagerTest.java | 160 ++---
.../GeneralUniformAssignmentBuilderTest.java | 2 +-
.../OptimizedUniformAssignmentBuilderTest.java | 2 +-
.../group/consumer/ConsumerGroupBuilder.java | 20 +-
.../group/consumer/ConsumerGroupTest.java | 2 +-
.../consumer/SubscribedTopicMetadataTest.java | 2 +-
.../consumer/TargetAssignmentBuilderTest.java | 6 +-
.../group/consumer/TopicMetadataTest.java | 4 +-
.../group/runtime/CoordinatorResultTest.java | 8 +-
31 files changed, 919 insertions(+), 921 deletions(-)
rename group-coordinator/src/main/java/org/apache/kafka/coordinator/group/{Record.java => CoordinatorRecord.java} (91%)
rename group-coordinator/src/main/java/org/apache/kafka/coordinator/group/{RecordHelpers.java => CoordinatorRecordHelpers.java} (90%)
rename group-coordinator/src/main/java/org/apache/kafka/coordinator/group/{RecordSerde.java => CoordinatorRecordSerde.java} (92%)
rename group-coordinator/src/test/java/org/apache/kafka/coordinator/group/{RecordHelpersTest.java => CoordinatorRecordHelpersTest.java} (89%)
rename group-coordinator/src/test/java/org/apache/kafka/coordinator/group/{RecordSerdeTest.java => CoordinatorRecordSerdeTest.java} (89%)
rename group-coordinator/src/test/java/org/apache/kafka/coordinator/group/{RecordTest.java => CoordinatorRecordTest.java} (84%)