|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/storage
|
scanned
|
directory
|
|
storage
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/storage/ProducerStateManagerBench.java
|
scanned
|
file
|
3.4 KB
|
ProducerStateManagerBench.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/timeline
|
scanned
|
directory
|
|
timeline
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/timeline/TimelineHashMapBenchmark.java
|
scanned
|
file
|
3.3 KB
|
TimelineHashMapBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util
|
scanned
|
directory
|
|
util
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/ByteUtilsBenchmark.java
|
scanned
|
file
|
22.3 KB
|
ByteUtilsBenchmark.java
|
.java
|
Java
|
text/html
|
|
apache-2.0 AND mit
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/ConcurrentMapBenchmark.java
|
scanned
|
file
|
7.8 KB
|
ConcurrentMapBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/Crc32CBenchmark.java
|
scanned
|
file
|
2.3 KB
|
Crc32CBenchmark.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/LICENSE
|
scanned
|
file
|
11.1 KB
|
LICENSE
|
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/LICENSE-binary
|
scanned
|
file
|
14.4 KB
|
LICENSE-binary
|
|
|
text/plain
|
|
apache-2.0 AND (unknown-license-reference AND bsd-new) AND (epl-2.0 AND unknown-license-reference) AND ((cddl-1.1 OR gpl-2.0 WITH classpath-exception-2.0) AND unknown-license-reference)
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses
|
scanned
|
directory
|
|
licenses
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/argparse-MIT
|
scanned
|
file
|
1.1 KB
|
argparse-MIT
|
|
|
text/plain
|
|
mit
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/CDDL+GPL-1.1
|
scanned
|
file
|
38.5 KB
|
CDDL+GPL-1.1
|
.1
|
|
text/plain
|
|
gpl-2.0 WITH classpath-exception-2.0 OR cddl-1.1
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/classgraph-MIT
|
scanned
|
file
|
1.1 KB
|
classgraph-MIT
|
|
|
text/plain
|
|
mit
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/eclipse-distribution-license-1.0
|
scanned
|
file
|
1.5 KB
|
eclipse-distribution-license-1.0
|
.0
|
|
text/plain
|
|
bsd-new
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/eclipse-public-license-2.0
|
scanned
|
file
|
13.8 KB
|
eclipse-public-license-2.0
|
.0
|
|
text/plain
|
|
epl-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/hdrHistogram-BSD-2-clause
|
scanned
|
file
|
2.1 KB
|
hdrHistogram-BSD-2-clause
|
|
|
text/plain
|
|
(cc0-1.0 OR bsd-simplified) AND bsd-simplified
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/jline-BSD-3-clause
|
scanned
|
file
|
1.5 KB
|
jline-BSD-3-clause
|
|
|
text/plain
|
|
bsd-new
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/jopt-simple-MIT
|
scanned
|
file
|
1.1 KB
|
jopt-simple-MIT
|
|
|
text/plain
|
|
mit
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/jsr305-BSD-3-clause
|
scanned
|
file
|
1.5 KB
|
jsr305-BSD-3-clause
|
|
|
text/plain
|
|
bsd-new
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/mock-oauth2-server-MIT
|
scanned
|
file
|
1.1 KB
|
mock-oauth2-server-MIT
|
|
|
text/plain
|
|
mit
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/paranamer-BSD-3-clause
|
scanned
|
file
|
1.7 KB
|
paranamer-BSD-3-clause
|
|
|
text/plain
|
|
bsd-new
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/pcollections-MIT
|
scanned
|
file
|
1.3 KB
|
pcollections-MIT
|
|
|
text/plain
|
|
mit
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/protobuf-java-BSD-3-clause
|
scanned
|
file
|
1.5 KB
|
protobuf-java-BSD-3-clause
|
|
|
text/plain
|
|
bsd-new
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/re2j-GO
|
scanned
|
file
|
1.6 KB
|
re2j-GO
|
|
|
text/plain
|
|
bsd-new
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/slf4j-MIT
|
scanned
|
file
|
1.1 KB
|
slf4j-MIT
|
|
|
text/plain
|
|
mit
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/licenses/zstd-jni-BSD-2-clause
|
scanned
|
file
|
1.3 KB
|
zstd-jni-BSD-2-clause
|
|
|
text/plain
|
|
bsd-simplified
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata
|
scanned
|
directory
|
|
metadata
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/.gitignore
|
scanned
|
file
|
6 bytes
|
.gitignore
|
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src
|
scanned
|
directory
|
|
src
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main
|
scanned
|
directory
|
|
main
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/common
|
scanned
|
directory
|
|
common
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/common/errors
|
scanned
|
directory
|
|
errors
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/common/errors/InvalidReplicaDirectoriesException.java
|
scanned
|
file
|
1.5 KB
|
InvalidReplicaDirectoriesException.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/controller
|
scanned
|
directory
|
|
controller
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/controller/AclControlManager.java
|
scanned
|
file
|
10.3 KB
|
AclControlManager.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/controller/ActivationRecordsGenerator.java
|
scanned
|
file
|
8.0 KB
|
ActivationRecordsGenerator.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/controller/BrokerControlState.java
|
scanned
|
file
|
1.4 KB
|
BrokerControlState.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/controller/BrokerControlStates.java
|
scanned
|
file
|
922 bytes
|
BrokerControlStates.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/controller/BrokerHeartbeatManager.java
|
scanned
|
file
|
18.4 KB
|
BrokerHeartbeatManager.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/controller/BrokerHeartbeatTracker.java
|
scanned
|
file
|
5.1 KB
|
BrokerHeartbeatTracker.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/main/java/org/apache/kafka/controller/BrokerIdAndEpoch.java
|
scanned
|
file
|
893 bytes
|
BrokerIdAndEpoch.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/controller/BrokersToElrs.java
|
scanned
|
file
|
5.8 KB
|
BrokersToElrs.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/controller/BrokersToIsrs.java
|
scanned
|
file
|
10.8 KB
|
BrokersToIsrs.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/controller/ClientQuotaControlManager.java
|
scanned
|
file
|
14.4 KB
|
ClientQuotaControlManager.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/controller/ClusterControlManager.java
|
scanned
|
file
|
37.2 KB
|
ClusterControlManager.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/main/java/org/apache/kafka/controller/ClusterFeatureSupportDescriber.java
|
scanned
|
file
|
1.1 KB
|
ClusterFeatureSupportDescriber.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/controller/ConfigurationControlManager.java
|
scanned
|
file
|
32.2 KB
|
ConfigurationControlManager.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/controller/ConfigurationValidator.java
|
scanned
|
file
|
1.8 KB
|
ConfigurationValidator.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/controller/Controller.java
|
scanned
|
file
|
16.3 KB
|
Controller.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/controller/ControllerRequestContext.java
|
scanned
|
file
|
3.9 KB
|
ControllerRequestContext.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/controller/ControllerResultAndOffset.java
|
scanned
|
file
|
2.3 KB
|
ControllerResultAndOffset.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/controller/ControllerResult.java
|
scanned
|
file
|
2.8 KB
|
ControllerResult.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/controller/DelegationTokenControlManager.java
|
scanned
|
file
|
15.6 KB
|
DelegationTokenControlManager.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/controller/errors
|
scanned
|
directory
|
|
errors
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/controller/errors/ControllerExceptions.java
|
scanned
|
file
|
2.8 KB
|
ControllerExceptions.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/controller/errors/EventHandlerExceptionInfo.java
|
scanned
|
file
|
9.0 KB
|
EventHandlerExceptionInfo.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/controller/errors/PeriodicControlTaskException.java
|
scanned
|
file
|
1.1 KB
|
PeriodicControlTaskException.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/controller/EventPerformanceMonitor.java
|
scanned
|
file
|
6.5 KB
|
EventPerformanceMonitor.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/main/java/org/apache/kafka/controller/FeatureControlManager.java
|
scanned
|
file
|
20.9 KB
|
FeatureControlManager.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/controller/KRaftVersionAccessor.java
|
scanned
|
file
|
1.4 KB
|
KRaftVersionAccessor.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/controller/metrics
|
scanned
|
directory
|
|
metrics
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/controller/metrics/BrokerRegistrationState.java
|
scanned
|
file
|
1.6 KB
|
BrokerRegistrationState.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/controller/metrics/ControllerMetadataMetrics.java
|
scanned
|
file
|
13.2 KB
|
ControllerMetadataMetrics.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/controller/metrics/ControllerMetadataMetricsPublisher.java
|
scanned
|
file
|
6.2 KB
|
ControllerMetadataMetricsPublisher.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/controller/metrics/ControllerMetricsChanges.java
|
scanned
|
file
|
7.2 KB
|
ControllerMetricsChanges.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/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java
|
scanned
|
file
|
12.2 KB
|
QuorumControllerMetrics.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/controller/OffsetControlManager.java
|
scanned
|
file
|
14.5 KB
|
OffsetControlManager.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/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java
|
scanned
|
file
|
24.5 KB
|
PartitionChangeBuilder.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/controller/PartitionReassignmentReplicas.java
|
scanned
|
file
|
5.1 KB
|
PartitionReassignmentReplicas.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/main/java/org/apache/kafka/controller/PartitionReassignmentRevert.java
|
scanned
|
file
|
3.7 KB
|
PartitionReassignmentRevert.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/main/java/org/apache/kafka/controller/PeriodicTaskControlManager.java
|
scanned
|
file
|
8.8 KB
|
PeriodicTaskControlManager.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/main/java/org/apache/kafka/controller/PeriodicTaskFlag.java
|
scanned
|
file
|
1011 bytes
|
PeriodicTaskFlag.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/controller/PeriodicTask.java
|
scanned
|
file
|
2.8 KB
|
PeriodicTask.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/main/java/org/apache/kafka/controller/ProducerIdControlManager.java
|
scanned
|
file
|
5.1 KB
|
ProducerIdControlManager.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/controller/QuorumController.java
|
scanned
|
file
|
93.1 KB
|
QuorumController.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/controller/QuorumFeatures.java
|
scanned
|
file
|
4.8 KB
|
QuorumFeatures.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/controller/RaftClientKRaftVersionAccessor.java
|
scanned
|
file
|
1.4 KB
|
RaftClientKRaftVersionAccessor.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/controller/ReplicationControlManager.java
|
scanned
|
file
|
121.8 KB
|
ReplicationControlManager.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/controller/ResultOrError.java
|
scanned
|
file
|
2.4 KB
|
ResultOrError.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/controller/ScramControlManager.java
|
scanned
|
file
|
14.6 KB
|
ScramControlManager.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/image
|
scanned
|
directory
|
|
image
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/java/org/apache/kafka/image/AclsDelta.java
|
scanned
|
file
|
4.5 KB
|
AclsDelta.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/image/AclsImage.java
|
scanned
|
file
|
1.9 KB
|
AclsImage.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/image/ClientQuotaDelta.java
|
scanned
|
file
|
2.7 KB
|
ClientQuotaDelta.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/image/ClientQuotaImage.java
|
scanned
|
file
|
3.3 KB
|
ClientQuotaImage.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/image/ClientQuotasDelta.java
|
scanned
|
file
|
3.5 KB
|
ClientQuotasDelta.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/image/ClientQuotasImage.java
|
scanned
|
file
|
7.7 KB
|
ClientQuotasImage.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/image/ClusterDelta.java
|
scanned
|
file
|
8.5 KB
|
ClusterDelta.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/image/ClusterImage.java
|
scanned
|
file
|
2.8 KB
|
ClusterImage.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/image/ConfigurationDelta.java
|
scanned
|
file
|
2.9 KB
|
ConfigurationDelta.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/image/ConfigurationImage.java
|
scanned
|
file
|
2.4 KB
|
ConfigurationImage.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/image/ConfigurationsDelta.java
|
scanned
|
file
|
4.2 KB
|
ConfigurationsDelta.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/image/ConfigurationsImage.java
|
scanned
|
file
|
3.2 KB
|
ConfigurationsImage.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/image/DelegationTokenDelta.java
|
scanned
|
file
|
3.8 KB
|
DelegationTokenDelta.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/image/DelegationTokenImage.java
|
scanned
|
file
|
2.5 KB
|
DelegationTokenImage.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|