8,627 results
« Page 45 of 87 »
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataKey.json scanned file 1.0 KB ConsumerGroupTargetAssignmentMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataValue.json scanned file 1.1 KB ConsumerGroupTargetAssignmentMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/GroupMetadataKey.json scanned file 1.0 KB GroupMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/GroupMetadataValue.json scanned file 2.9 KB GroupMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/LegacyOffsetCommitKey.json scanned file 1.2 KB LegacyOffsetCommitKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/LegacyOffsetCommitValue.json scanned file 1.3 KB LegacyOffsetCommitValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/OffsetCommitKey.json scanned file 1.2 KB OffsetCommitKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/OffsetCommitValue.json scanned file 2.0 KB OffsetCommitValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupCurrentMemberAssignmentKey.json scanned file 1.1 KB ShareGroupCurrentMemberAssignmentKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupCurrentMemberAssignmentValue.json scanned file 1.9 KB ShareGroupCurrentMemberAssignmentValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupMemberMetadataKey.json scanned file 1.1 KB ShareGroupMemberMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupMemberMetadataValue.json scanned file 1.4 KB ShareGroupMemberMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupMetadataKey.json scanned file 1.0 KB ShareGroupMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupMetadataValue.json scanned file 1.1 KB ShareGroupMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupStatePartitionMetadataKey.json scanned file 1.0 KB ShareGroupStatePartitionMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupStatePartitionMetadataValue.json scanned file 2.1 KB ShareGroupStatePartitionMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMemberKey.json scanned file 1.1 KB ShareGroupTargetAssignmentMemberKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMemberValue.json scanned file 1.3 KB ShareGroupTargetAssignmentMemberValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMetadataKey.json scanned file 1.0 KB ShareGroupTargetAssignmentMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMetadataValue.json scanned file 1.1 KB ShareGroupTargetAssignmentMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupCurrentMemberAssignmentKey.json scanned file 1.1 KB StreamsGroupCurrentMemberAssignmentKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupCurrentMemberAssignmentValue.json scanned file 3.0 KB StreamsGroupCurrentMemberAssignmentValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupMemberMetadataKey.json scanned file 1.1 KB StreamsGroupMemberMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupMemberMetadataValue.json scanned file 2.7 KB StreamsGroupMemberMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupMetadataKey.json scanned file 1.0 KB StreamsGroupMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupMetadataValue.json scanned file 1.9 KB StreamsGroupMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMemberKey.json scanned file 1.1 KB StreamsGroupTargetAssignmentMemberKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMemberValue.json scanned file 1.7 KB StreamsGroupTargetAssignmentMemberValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMetadataKey.json scanned file 1.0 KB StreamsGroupTargetAssignmentMetadataKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMetadataValue.json scanned file 1.1 KB StreamsGroupTargetAssignmentMetadataValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTopologyKey.json scanned file 1.0 KB StreamsGroupTopologyKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTopologyValue.json scanned file 4.0 KB StreamsGroupTopologyValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator scanned directory coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group scanned directory group
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/Assertions.java scanned file 16.9 KB Assertions.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/AssignmentTestUtil.java scanned file 4.6 KB AssignmentTestUtil.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor scanned directory assignor
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/GroupSpecImplTest.java scanned file 4.4 KB GroupSpecImplTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilderTest.java scanned file 26.6 KB OptimizedUniformAssignmentBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeAssignorTest.java scanned file 30.0 KB RangeAssignorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeSetTest.java scanned file 6.0 KB RangeSetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/SimpleAssignorTest.java scanned file 35.4 KB SimpleAssignorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilderTest.java scanned file 24.5 KB UniformHeterogeneousAssignmentBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/classic scanned directory classic
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/classic/ClassicGroupMemberTest.java scanned file 10.8 KB ClassicGroupMemberTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/classic/ClassicGroupTest.java scanned file 61.8 KB ClassicGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupConfigManagerTest.java scanned file 3.6 KB GroupConfigManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupConfigTest.java scanned file 14.6 KB GroupConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfigTest.java scanned file 23.0 KB GroupCoordinatorConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpersTest.java scanned file 30.5 KB GroupCoordinatorRecordHelpersTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordSerdeTest.java scanned file 9.9 KB GroupCoordinatorRecordSerdeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorServiceTest.java scanned file 277.8 KB GroupCoordinatorServiceTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java scanned file 104.6 KB GroupCoordinatorShardTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTestContext.java scanned file 72.2 KB GroupMetadataManagerTestContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java scanned file 1.2 MB GroupMetadataManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics scanned directory metrics
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShardTest.java scanned file 2.2 KB GroupCoordinatorMetricsShardTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsTest.java scanned file 16.5 KB GroupCoordinatorMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/MetricsTestUtils.java scanned file 2.5 KB MetricsTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/MockPartitionAssignor.java scanned file 2.3 KB MockPartitionAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern scanned directory modern
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/AssignmentTest.java scanned file 3.1 KB AssignmentTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer scanned directory consumer
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupBuilder.java scanned file 4.1 KB ConsumerGroupBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupMemberTest.java scanned file 18.0 KB ConsumerGroupMemberTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupTest.java scanned file 85.3 KB ConsumerGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilderTest.java scanned file 47.5 KB CurrentAssignmentBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ResolvedRegularExpressionTest.java scanned file 2.1 KB ResolvedRegularExpressionTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/MemberAssignmentImplTest.java scanned file 1.9 KB MemberAssignmentImplTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share scanned directory share
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupAssignmentBuilderTest.java scanned file 6.9 KB ShareGroupAssignmentBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupBuilder.java scanned file 3.4 KB ShareGroupBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfigTest.java scanned file 7.7 KB ShareGroupConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMemberTest.java scanned file 7.6 KB ShareGroupMemberTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupTest.java scanned file 18.9 KB ShareGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/SubscribedTopicMetadataTest.java scanned file 3.8 KB SubscribedTopicMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilderTest.java scanned file 36.6 KB TargetAssignmentBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TopicIdsTest.java scanned file 7.1 KB TopicIdsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/UnionSetTest.java scanned file 3.9 KB UnionSetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/NetworkPartitionMetadataClientTest.java scanned file 52.0 KB NetworkPartitionMetadataClientTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/NoOpPartitionAssignor.java scanned file 1.8 KB NoOpPartitionAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetAndMetadataTest.java scanned file 6.3 KB OffsetAndMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetExpirationConditionImplTest.java scanned file 2.9 KB OffsetExpirationConditionImplTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java scanned file 148.2 KB OffsetMetadataManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/ShareGroupAutoOffsetResetStrategyTest.java scanned file 6.6 KB ShareGroupAutoOffsetResetStrategyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams scanned directory streams
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor scanned directory assignor
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImplTest.java scanned file 1.7 KB GroupSpecImplTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/MockAssignorTest.java scanned file 8.7 KB MockAssignorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessStateTest.java scanned file 4.2 KB ProcessStateTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignorTest.java scanned file 79.7 KB StickyTaskAssignorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/CurrentAssignmentBuilderTest.java scanned file 43.6 KB CurrentAssignmentBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/MockTaskAssignor.java scanned file 2.8 KB MockTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpersTest.java scanned file 39.5 KB StreamsCoordinatorRecordHelpersTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupBuilder.java scanned file 4.8 KB StreamsGroupBuilder.java .java Java text/x-java apache-2.0