266 results
« Page 1 of 3 »
Search: kafka_neu-1778570057504.zip-extract/kaf…
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator scanned directory group-coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/.gitignore scanned file 6 bytes .gitignore text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api scanned directory group-coordinator-api
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator scanned directory coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group scanned directory group
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api scanned directory api
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 scanned directory assignor
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 scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator scanned directory coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group scanned directory group
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor scanned directory assignor
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 scanned directory classic
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 scanned directory metrics
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 scanned directory modern
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 scanned directory consumer
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 scanned directory share
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
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams scanned directory streams
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor scanned directory assignor
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