|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/DelegationTokenData.java
|
scanned
|
file
|
2.8 KB
|
DelegationTokenData.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/FinalizedControllerFeatures.java
|
scanned
|
file
|
1.6 KB
|
FinalizedControllerFeatures.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java
|
scanned
|
file
|
12.8 KB
|
KafkaConfigSchema.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/LeaderAndIsr.java
|
scanned
|
file
|
5.4 KB
|
LeaderAndIsr.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/LeaderConstants.java
|
scanned
|
file
|
1.2 KB
|
LeaderConstants.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/LeaderRecoveryState.java
|
scanned
|
file
|
2.3 KB
|
LeaderRecoveryState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java
|
scanned
|
file
|
16.5 KB
|
ListenerInfo.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/MetadataCache.java
|
scanned
|
file
|
9.4 KB
|
MetadataCache.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/metadata/MetadataRecordSerde.java
|
scanned
|
file
|
1.3 KB
|
MetadataRecordSerde.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/MetadataVersionChangeTest.java
|
scanned
|
file
|
3.2 KB
|
MetadataVersionChangeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/node/ClientQuotasImageNodeTest.java
|
scanned
|
file
|
4.4 KB
|
ClientQuotasImageNodeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/node/ClusterImageBrokersNodeTest.java
|
scanned
|
file
|
3.0 KB
|
ClusterImageBrokersNodeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/node/ClusterImageControllersNodeTest.java
|
scanned
|
file
|
2.6 KB
|
ClusterImageControllersNodeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/node/ClusterImageNodeTest.java
|
scanned
|
file
|
1.9 KB
|
ClusterImageNodeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/node/ConfigurationImageNodeTest.java
|
scanned
|
file
|
3.0 KB
|
ConfigurationImageNodeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/node/ConfigurationsImageNodeTest.java
|
scanned
|
file
|
3.1 KB
|
ConfigurationsImageNodeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/node/MetadataImageNodeTest.java
|
scanned
|
file
|
1.9 KB
|
MetadataImageNodeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/image/node/printer/MetadataNodeRedactionCriteriaTest.java
|
scanned
|
file
|
4.3 KB
|
MetadataNodeRedactionCriteriaTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|