380 results
« Page 3 of 4 »
Search: kafka_neu-1778570057504.zip-extract/kaf…
View the resource tree
Packages
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
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/controller/PeriodicTaskControlManagerTest.java scanned file 10.5 KB PeriodicTaskControlManagerTest.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/ProducerIdControlManagerTest.java scanned file 6.6 KB ProducerIdControlManagerTest.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/QuorumControllerIntegrationTestUtils.java scanned file 10.1 KB QuorumControllerIntegrationTestUtils.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/QuorumControllerMetricsIntegrationTest.java scanned file 9.6 KB QuorumControllerMetricsIntegrationTest.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/QuorumControllerTestEnv.java scanned file 8.5 KB QuorumControllerTestEnv.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/QuorumControllerTest.java scanned file 90.7 KB QuorumControllerTest.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/QuorumFeaturesTest.java scanned file 4.8 KB QuorumFeaturesTest.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/ReplicationControlManagerTest.java scanned file 185.6 KB ReplicationControlManagerTest.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/ResultOrErrorTest.java scanned file 2.5 KB ResultOrErrorTest.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/ScramCredentialValueTest.java scanned file 2.9 KB ScramCredentialValueTest.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/image scanned directory image
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/AclsDeltaTest.java scanned file 4.9 KB AclsDeltaTest.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/image/AclsImageTest.java scanned file 4.2 KB AclsImageTest.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/image/ClientQuotasImageTest.java scanned file 6.0 KB ClientQuotasImageTest.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/image/ClusterImageTest.java scanned file 15.1 KB ClusterImageTest.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/image/ConfigurationsImageTest.java scanned file 5.8 KB ConfigurationsImageTest.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/image/DelegationTokenImageTest.java scanned file 6.3 KB DelegationTokenImageTest.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/image/FakeSnapshotWriter.java scanned file 2.4 KB FakeSnapshotWriter.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/image/FeaturesDeltaTest.java scanned file 2.4 KB FeaturesDeltaTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/FeaturesImageTest.java scanned file 7.2 KB FeaturesImageTest.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/image/ImageDowngradeTest.java scanned file 6.5 KB ImageDowngradeTest.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/image/loader scanned directory loader
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/loader/MetadataBatchLoaderTest.java scanned file 20.5 KB MetadataBatchLoaderTest.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/image/loader/MetadataLoaderTest.java scanned file 40.1 KB MetadataLoaderTest.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/image/loader/metrics scanned directory metrics
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/loader/metrics/MetadataLoaderMetricsTest.java scanned file 14.9 KB MetadataLoaderMetricsTest.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/image/MetadataImageTest.java scanned file 6.4 KB MetadataImageTest.java .java Java text/x-java apache-2.0