5,643 results
« Page 27 of 57 »
Programming language: Java
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/FieldSpec.java scanned file 27.7 KB FieldSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/FieldType.java scanned file 13.4 KB FieldType.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/HeaderGenerator.java scanned file 3.3 KB HeaderGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/IsNullConditional.java scanned file 4.5 KB IsNullConditional.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java scanned file 24.2 KB JsonConverterGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/MessageClassGenerator.java scanned file 1.3 KB MessageClassGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java scanned file 88.5 KB MessageDataGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/MessageGenerator.java scanned file 16.6 KB MessageGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/MessageSpec.java scanned file 7.1 KB MessageSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/MessageSpecType.java scanned file 1.4 KB MessageSpecType.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/MetadataJsonConvertersGenerator.java scanned file 5.0 KB MetadataJsonConvertersGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/MetadataRecordTypeGenerator.java scanned file 7.2 KB MetadataRecordTypeGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/RequestListenerType.java scanned file 1014 bytes RequestListenerType.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java scanned file 15.5 KB SchemaGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/StructRegistry.java scanned file 7.1 KB StructRegistry.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/StructSpec.java scanned file 4.1 KB StructSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/Target.java scanned file 3.4 KB Target.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/TypeClassGenerator.java scanned file 1.4 KB TypeClassGenerator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/VersionConditional.java scanned file 9.0 KB VersionConditional.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/Versions.java scanned file 6.7 KB Versions.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/CheckerTestUtils.java scanned file 3.9 KB CheckerTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/CheckerUtilsTest.java scanned file 3.1 KB CheckerUtilsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/EvolutionVerifierTest.java scanned file 11.1 KB EvolutionVerifierTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/FieldDomainTest.java scanned file 2.1 KB FieldDomainTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/MetadataSchemaCheckerToolTest.java scanned file 4.0 KB MetadataSchemaCheckerToolTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/checker/UnifierTest.java scanned file 10.4 KB UnifierTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/CodeBufferTest.java scanned file 2.7 KB CodeBufferTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/EntityTypeTest.java scanned file 3.7 KB EntityTypeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/IsNullConditionalTest.java scanned file 4.3 KB IsNullConditionalTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/MessageDataGeneratorTest.java scanned file 15.0 KB MessageDataGeneratorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/MessageGeneratorTest.java scanned file 6.4 KB MessageGeneratorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/StructRegistryTest.java scanned file 8.0 KB StructRegistryTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/StructSpecTest.java scanned file 3.2 KB StructSpecTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/VersionConditionalTest.java scanned file 8.8 KB VersionConditionalTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/VersionsTest.java scanned file 4.6 KB VersionsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/ConsumerGroupPartitionAssignor.java scanned file 1.0 KB ConsumerGroupPartitionAssignor.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupAssignment.java scanned file 1.8 KB GroupAssignment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupSpec.java scanned file 2.8 KB GroupSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberAssignment.java scanned file 1.1 KB MemberAssignment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberSubscription.java scanned file 1.5 KB MemberSubscription.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/package-info.java scanned file 964 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignorException.java scanned file 1.3 KB PartitionAssignorException.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignor.java scanned file 1.5 KB PartitionAssignor.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/ShareGroupPartitionAssignor.java scanned file 1021 bytes ShareGroupPartitionAssignor.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscribedTopicDescriber.java scanned file 1.8 KB SubscribedTopicDescriber.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscriptionType.java scanned file 1.4 KB SubscriptionType.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/assignor/AssignorHelpers.java scanned file 2.8 KB AssignorHelpers.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/assignor/RangeAssignor.java scanned file 12.9 KB RangeAssignor.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/assignor/RangeSet.java scanned file 5.9 KB RangeSet.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/assignor/SimpleAssignor.java scanned file 3.6 KB SimpleAssignor.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/assignor/SimpleHeterogeneousAssignmentBuilder.java scanned file 22.5 KB SimpleHeterogeneousAssignmentBuilder.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/assignor/SimpleHomogeneousAssignmentBuilder.java scanned file 19.6 KB SimpleHomogeneousAssignmentBuilder.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/assignor/UniformAssignor.java scanned file 3.8 KB UniformAssignor.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/assignor/UniformHeterogeneousAssignmentBuilder.java scanned file 39.1 KB UniformHeterogeneousAssignmentBuilder.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/assignor/UniformHomogeneousAssignmentBuilder.java scanned file 11.7 KB UniformHomogeneousAssignmentBuilder.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/classic/ClassicGroup.java scanned file 51.1 KB ClassicGroup.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/classic/ClassicGroupMember.java scanned file 12.5 KB ClassicGroupMember.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/classic/ClassicGroupState.java scanned file 5.8 KB ClassicGroupState.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/CommitPartitionValidator.java scanned file 1.5 KB CommitPartitionValidator.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/ConsumerGroupMigrationPolicy.java scanned file 2.7 KB ConsumerGroupMigrationPolicy.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/GroupConfig.java scanned file 19.3 KB GroupConfig.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/GroupConfigManager.java scanned file 3.4 KB GroupConfigManager.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/GroupCoordinatorConfig.java scanned file 58.3 KB GroupCoordinatorConfig.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/GroupCoordinator.java scanned file 19.6 KB GroupCoordinator.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/GroupCoordinatorRecordHelpers.java scanned file 30.1 KB GroupCoordinatorRecordHelpers.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/GroupCoordinatorRecordSerde.java scanned file 1.8 KB GroupCoordinatorRecordSerde.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/GroupCoordinatorService.java scanned file 113.4 KB GroupCoordinatorService.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/GroupCoordinatorShard.java scanned file 55.5 KB GroupCoordinatorShard.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/Group.java scanned file 6.6 KB Group.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/GroupMetadataManager.java scanned file 398.2 KB GroupMetadataManager.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/metrics/GroupCoordinatorMetrics.java scanned file 24.5 KB GroupCoordinatorMetrics.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/metrics/GroupCoordinatorMetricsShard.java scanned file 10.7 KB GroupCoordinatorMetricsShard.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/metrics/GroupCoordinatorRuntimeMetrics.java scanned file 1.2 KB GroupCoordinatorRuntimeMetrics.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/modern/Assignment.java scanned file 3.5 KB Assignment.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/modern/consumer/ConsumerGroup.java scanned file 53.5 KB ConsumerGroup.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/modern/consumer/ConsumerGroupMember.java scanned file 20.3 KB ConsumerGroupMember.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/modern/consumer/CurrentAssignmentBuilder.java scanned file 21.1 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/modern/consumer/ResolvedRegularExpression.java scanned file 1.7 KB ResolvedRegularExpression.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/modern/GroupSpecImpl.java scanned file 5.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/modern/MemberAssignmentImpl.java scanned file 1.8 KB MemberAssignmentImpl.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/modern/MemberState.java scanned file 2.4 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/modern/MemberSubscriptionAndAssignmentImpl.java scanned file 3.7 KB MemberSubscriptionAndAssignmentImpl.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/modern/ModernGroup.java scanned file 19.2 KB ModernGroup.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/modern/ModernGroupMember.java scanned file 4.5 KB ModernGroupMember.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/modern/share/ShareGroupAssignmentBuilder.java scanned file 6.0 KB ShareGroupAssignmentBuilder.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/modern/share/ShareGroupConfig.java scanned file 10.8 KB ShareGroupConfig.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/modern/share/ShareGroup.java scanned file 10.3 KB ShareGroup.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/modern/share/ShareGroupMember.java scanned file 10.2 KB ShareGroupMember.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/modern/SubscribedTopicDescriberImpl.java scanned file 3.8 KB SubscribedTopicDescriberImpl.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/modern/SubscriptionCount.java scanned file 2.8 KB SubscriptionCount.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/modern/TargetAssignmentBuilder.java scanned file 17.8 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/modern/TopicIds.java scanned file 8.4 KB TopicIds.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/modern/UnionSet.java scanned file 5.8 KB UnionSet.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/NetworkPartitionMetadataClient.java scanned file 16.6 KB NetworkPartitionMetadataClient.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/OffsetAndMetadata.java scanned file 6.8 KB OffsetAndMetadata.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/OffsetExpirationConditionImpl.java scanned file 2.3 KB OffsetExpirationConditionImpl.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/OffsetExpirationCondition.java scanned file 1.6 KB OffsetExpirationCondition.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/OffsetMetadataManager.java scanned file 56.7 KB OffsetMetadataManager.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/PartitionMetadataClient.java scanned file 1.7 KB PartitionMetadataClient.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/ShareGroupAutoOffsetResetStrategy.java scanned file 5.9 KB ShareGroupAutoOffsetResetStrategy.java .java Java text/x-java apache-2.0