8,627 results
« Page 49 of 87 »
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/MetadataVersionConfigValidator.java scanned file 3.0 KB MetadataVersionConfigValidator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/OptionalStringComparator.java scanned file 1.4 KB OptionalStringComparator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/PartitionRegistration.java scanned file 18.1 KB PartitionRegistration.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement scanned directory placement
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement/ClusterDescriber.java scanned file 1.3 KB ClusterDescriber.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement/DefaultDirProvider.java scanned file 1.3 KB DefaultDirProvider.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement/PartitionAssignment.java scanned file 2.4 KB PartitionAssignment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement/PlacementSpec.java scanned file 1.1 KB PlacementSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement/ReplicaPlacer.java scanned file 1.6 KB ReplicaPlacer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement/StripedReplicaPlacer.java scanned file 16.6 KB StripedReplicaPlacer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement/TopicAssignment.java scanned file 1.1 KB TopicAssignment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/placement/UsableBroker.java scanned file 1.1 KB UsableBroker.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/properties scanned directory properties
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/properties/MetaPropertiesEnsemble.java scanned file 22.8 KB MetaPropertiesEnsemble.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/properties/MetaProperties.java scanned file 8.2 KB MetaProperties.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/properties/MetaPropertiesVersion.java scanned file 2.4 KB MetaPropertiesVersion.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/properties/PropertiesUtils.java scanned file 3.4 KB PropertiesUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/publisher scanned directory publisher
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/publisher/AclPublisher.java scanned file 5.5 KB AclPublisher.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/publisher/DelegationTokenPublisher.java scanned file 3.3 KB DelegationTokenPublisher.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/publisher/DynamicClientQuotaPublisher.java scanned file 2.5 KB DynamicClientQuotaPublisher.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/publisher/FeaturesPublisher.java scanned file 2.8 KB FeaturesPublisher.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/publisher/ScramPublisher.java scanned file 2.7 KB ScramPublisher.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/Replicas.java scanned file 7.5 KB Replicas.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/ScramCredentialData.java scanned file 2.9 KB ScramCredentialData.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/storage scanned directory storage
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/storage/FormatterException.java scanned file 1.0 KB FormatterException.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/storage/Formatter.java scanned file 20.9 KB Formatter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/storage/ScramParser.java scanned file 11.2 KB ScramParser.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/util scanned directory util
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/util/BatchFileReader.java scanned file 6.4 KB BatchFileReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/util/BatchFileWriter.java scanned file 4.4 KB BatchFileWriter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/util/RecordRedactor.java scanned file 2.6 KB RecordRedactor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/util/SnapshotFileReader.java scanned file 7.6 KB SnapshotFileReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/VersionRange.java scanned file 2.2 KB VersionRange.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources scanned directory resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common scanned directory common
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata scanned directory metadata
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/AbortTransactionRecord.json scanned file 1.1 KB AbortTransactionRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/AccessControlEntryRecord.json scanned file 1.7 KB AccessControlEntryRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/BeginTransactionRecord.json scanned file 1.1 KB BeginTransactionRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/BrokerRegistrationChangeRecord.json scanned file 1.8 KB BrokerRegistrationChangeRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/ClearElrRecord.json scanned file 1.1 KB ClearElrRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/ClientQuotaRecord.json scanned file 1.7 KB ClientQuotaRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/ConfigRecord.json scanned file 1.5 KB ConfigRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/DelegationTokenRecord.json scanned file 1.8 KB DelegationTokenRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/EndTransactionRecord.json scanned file 941 bytes EndTransactionRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/FeatureLevelRecord.json scanned file 1.4 KB FeatureLevelRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/FenceBrokerRecord.json scanned file 1.2 KB FenceBrokerRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/NoOpRecord.json scanned file 928 bytes NoOpRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/PartitionChangeRecord.json scanned file 3.7 KB PartitionChangeRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/PartitionRecord.json scanned file 3.2 KB PartitionRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/ProducerIdsRecord.json scanned file 1.4 KB ProducerIdsRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RegisterBrokerRecord.json scanned file 3.2 KB RegisterBrokerRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RegisterControllerRecord.json scanned file 2.4 KB RegisterControllerRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RemoveAccessControlEntryRecord.json scanned file 1.0 KB RemoveAccessControlEntryRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RemoveDelegationTokenRecord.json scanned file 1.0 KB RemoveDelegationTokenRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RemoveTopicRecord.json scanned file 1.1 KB RemoveTopicRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RemoveUserScramCredentialRecord.json scanned file 1.1 KB RemoveUserScramCredentialRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/TopicRecord.json scanned file 1.1 KB TopicRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/UnfenceBrokerRecord.json scanned file 1.2 KB UnfenceBrokerRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/UnregisterBrokerRecord.json scanned file 1.1 KB UnregisterBrokerRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/UserScramCredentialRecord.json scanned file 1.6 KB UserScramCredentialRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/ZkMigrationRecord.json scanned file 1.8 KB ZkMigrationRecord.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller scanned directory controller
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/AclControlManagerTest.java scanned file 20.0 KB AclControlManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/ActivationRecordsGeneratorTest.java scanned file 5.5 KB ActivationRecordsGeneratorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/BrokerHeartbeatManagerTest.java scanned file 11.8 KB BrokerHeartbeatManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/BrokerHeartbeatTrackerTest.java scanned file 4.6 KB BrokerHeartbeatTrackerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/BrokersToIsrsTest.java scanned file 4.7 KB BrokersToIsrsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/BrokerToElrsTest.java scanned file 2.9 KB BrokerToElrsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/ClientQuotaControlManagerTest.java scanned file 22.7 KB ClientQuotaControlManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/ClusterControlManagerTest.java scanned file 59.0 KB ClusterControlManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/ConfigurationControlManagerTest.java scanned file 27.3 KB ConfigurationControlManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/ControllerRequestContextUtil.java scanned file 2.6 KB ControllerRequestContextUtil.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/errors scanned directory errors
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/errors/ControllerExceptionsTest.java scanned file 4.1 KB ControllerExceptionsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/errors/EventHandlerExceptionInfoTest.java scanned file 9.5 KB EventHandlerExceptionInfoTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/EventPerformanceMonitorTest.java scanned file 5.0 KB EventPerformanceMonitorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/FeatureControlManagerTest.java scanned file 25.4 KB FeatureControlManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/metrics scanned directory metrics
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetadataMetricsPublisherTest.java scanned file 6.7 KB ControllerMetadataMetricsPublisherTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetadataMetricsTest.java scanned file 13.1 KB ControllerMetadataMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetricsChangesTest.java scanned file 12.1 KB ControllerMetricsChangesTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/metrics/ControllerMetricsTestUtils.java scanned file 3.6 KB ControllerMetricsTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/metrics/QuorumControllerMetricsTest.java scanned file 10.9 KB QuorumControllerMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/MockAclMutator.java scanned file 3.7 KB MockAclMutator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/MockRaftClient.java scanned file 29.6 KB MockRaftClient.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/MockRaftClientListener.java scanned file 4.2 KB MockRaftClientListener.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/MockRaftClientTestEnv.java scanned file 8.1 KB MockRaftClientTestEnv.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/MockRaftClientTest.java scanned file 6.8 KB MockRaftClientTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/OffsetControlManagerTest.java scanned file 12.3 KB OffsetControlManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/PartitionChangeBuilderTest.java scanned file 59.3 KB PartitionChangeBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/PartitionReassignmentReplicasTest.java scanned file 9.9 KB PartitionReassignmentReplicasTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/PartitionReassignmentRevertTest.java scanned file 5.9 KB PartitionReassignmentRevertTest.java .java Java text/x-java apache-2.0