5,643 results
« Page 28 of 57 »
Programming language: Java
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/AssignmentMemberSpec.java scanned file 2.8 KB AssignmentMemberSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupAssignment.java scanned file 1.1 KB GroupAssignment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImpl.java scanned file 1.4 KB GroupSpecImpl.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpec.java scanned file 1.2 KB GroupSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignment.java scanned file 1.7 KB MemberAssignment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MockAssignor.java scanned file 4.8 KB MockAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessState.java scanned file 7.0 KB ProcessState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignor.java scanned file 20.2 KB StickyTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskAssignorException.java scanned file 1.3 KB TaskAssignorException.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskAssignor.java scanned file 1.5 KB TaskAssignor.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskId.java scanned file 1.5 KB TaskId.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TopologyDescriber.java scanned file 2.1 KB TopologyDescriber.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/CurrentAssignmentBuilder.java scanned file 27.7 KB CurrentAssignmentBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/MemberState.java scanned file 2.3 KB MemberState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpers.java scanned file 19.1 KB StreamsCoordinatorRecordHelpers.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupHeartbeatResult.java scanned file 1.6 KB StreamsGroupHeartbeatResult.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java scanned file 44.1 KB StreamsGroup.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java scanned file 16.3 KB StreamsGroupMember.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsTopology.java scanned file 8.2 KB StreamsTopology.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilder.java scanned file 12.4 KB TargetAssignmentBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TasksTuple.java scanned file 7.5 KB TasksTuple.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TasksTupleWithEpochs.java scanned file 9.0 KB TasksTupleWithEpochs.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TopicMetadata.java scanned file 1.8 KB TopicMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ChangelogTopics.java scanned file 4.8 KB ChangelogTopics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredInternalTopic.java scanned file 2.9 KB ConfiguredInternalTopic.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredSubtopology.java scanned file 3.9 KB ConfiguredSubtopology.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredTopology.java scanned file 4.0 KB ConfiguredTopology.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/CopartitionedTopicsEnforcer.java scanned file 9.0 KB CopartitionedTopicsEnforcer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/EndpointToPartitionsManager.java scanned file 7.2 KB EndpointToPartitionsManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManager.java scanned file 17.5 KB InternalTopicManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/RepartitionTopics.java scanned file 8.8 KB RepartitionTopics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/TopicConfigurationException.java scanned file 1.8 KB TopicConfigurationException.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TopologyMetadata.java scanned file 3.6 KB TopologyMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java scanned file 16.2 KB Utils.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/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/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/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/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/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/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/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/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
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMemberTest.java scanned file 23.1 KB StreamsGroupMemberTest.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/StreamsGroupTest.java scanned file 55.5 KB StreamsGroupTest.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/StreamsTopologyTest.java scanned file 15.5 KB StreamsTopologyTest.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/TargetAssignmentBuilderTest.java scanned file 33.0 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/streams/TaskAssignmentTestUtil.java scanned file 5.1 KB TaskAssignmentTestUtil.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/TasksTupleTest.java scanned file 7.3 KB TasksTupleTest.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/TasksTupleWithEpochsTest.java scanned file 10.2 KB TasksTupleWithEpochsTest.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/TopicMetadataTest.java scanned file 2.8 KB TopicMetadataTest.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/topics/ChangelogTopicsTest.java scanned file 8.1 KB ChangelogTopicsTest.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/topics/ConfiguredInternalTopicTest.java scanned file 3.0 KB ConfiguredInternalTopicTest.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/topics/ConfiguredSubtopologyTest.java scanned file 4.3 KB ConfiguredSubtopologyTest.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/topics/ConfiguredTopologyTest.java scanned file 5.0 KB ConfiguredTopologyTest.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/topics/CopartitionedTopicsEnforcerTest.java scanned file 9.6 KB CopartitionedTopicsEnforcerTest.java .java Java text/x-java apache-2.0