|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTestUtils.java
|
scanned
|
file
|
1.1 KB
|
MetadataVersionTestUtils.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/ProducerIdsBlockTest.java
|
scanned
|
file
|
2.7 KB
|
ProducerIdsBlockTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/fault
|
scanned
|
directory
|
|
fault
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/fault/LoggingFaultHandlerTest.java
|
scanned
|
file
|
1.9 KB
|
LoggingFaultHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/fault/MockFaultHandler.java
|
scanned
|
file
|
2.4 KB
|
MockFaultHandler.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/fault/ProcessTerminatingFaultHandlerTest.java
|
scanned
|
file
|
2.9 KB
|
ProcessTerminatingFaultHandlerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable
|
scanned
|
directory
|
|
immutable
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/DelegationChecker.java
|
scanned
|
file
|
7.8 KB
|
DelegationChecker.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/pcollections
|
scanned
|
directory
|
|
pcollections
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableMapTest.java
|
scanned
|
file
|
15.0 KB
|
PCollectionsImmutableMapTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableNavigableSetTest.java
|
scanned
|
file
|
20.7 KB
|
PCollectionsImmutableNavigableSetTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableSetTest.java
|
scanned
|
file
|
12.2 KB
|
PCollectionsImmutableSetTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/IntegrationTestUtils.java
|
scanned
|
file
|
3.3 KB
|
IntegrationTestUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/metrics
|
scanned
|
directory
|
|
metrics
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/metrics/KafkaMetricsGroupTest.java
|
scanned
|
file
|
1.4 KB
|
KafkaMetricsGroupTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/metrics/KafkaYammerMetricsTest.java
|
scanned
|
file
|
3.4 KB
|
KafkaYammerMetricsTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/metrics/TimeRatioTest.java
|
scanned
|
file
|
2.4 KB
|
TimeRatioTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/mutable
|
scanned
|
directory
|
|
mutable
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/mutable/BoundedListTest.java
|
scanned
|
file
|
7.4 KB
|
BoundedListTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/network
|
scanned
|
directory
|
|
network
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/network/EndpointReadyFuturesTest.java
|
scanned
|
file
|
7.2 KB
|
EndpointReadyFuturesTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/purgatory
|
scanned
|
directory
|
|
purgatory
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/purgatory/DelayedOperationTest.java
|
scanned
|
file
|
12.7 KB
|
DelayedOperationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/quota
|
scanned
|
directory
|
|
quota
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/quota/QuotaUtilsTest.java
|
scanned
|
file
|
5.9 KB
|
QuotaUtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/record
|
scanned
|
directory
|
|
record
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/record/BrokerCompressionTypeTest.java
|
scanned
|
file
|
2.8 KB
|
BrokerCompressionTypeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/share
|
scanned
|
directory
|
|
share
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/share/persister
|
scanned
|
directory
|
|
persister
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/share/persister/DefaultStatePersisterTest.java
|
scanned
|
file
|
79.8 KB
|
DefaultStatePersisterTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/share/persister/PersisterStateManagerTest.java
|
scanned
|
file
|
199.4 KB
|
PersisterStateManagerTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util
|
scanned
|
directory
|
|
util
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/CommandLineUtilsTest.java
|
scanned
|
file
|
15.5 KB
|
CommandLineUtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/CsvTest.java
|
scanned
|
file
|
2.6 KB
|
CsvTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/DeadlineTest.java
|
scanned
|
file
|
2.6 KB
|
DeadlineTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/FileLockTest.java
|
scanned
|
file
|
3.2 KB
|
FileLockTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/FutureUtilsTest.java
|
scanned
|
file
|
5.5 KB
|
FutureUtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/InterBrokerSendThreadTest.java
|
scanned
|
file
|
14.2 KB
|
InterBrokerSendThreadTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/JsonTest.java
|
scanned
|
file
|
9.9 KB
|
JsonTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/MockRandom.java
|
scanned
|
file
|
1.3 KB
|
MockRandom.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/MockScheduler.java
|
scanned
|
file
|
6.0 KB
|
MockScheduler.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/MockTime.java
|
scanned
|
file
|
1.7 KB
|
MockTime.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/ShutdownableThreadTest.java
|
scanned
|
file
|
5.5 KB
|
ShutdownableThreadTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer
|
scanned
|
directory
|
|
timer
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/MockTimer.java
|
scanned
|
file
|
2.8 KB
|
MockTimer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/SystemTimerReaperTest.java
|
scanned
|
file
|
2.7 KB
|
SystemTimerReaperTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTaskListTest.java
|
scanned
|
file
|
4.0 KB
|
TimerTaskListTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/TimerTest.java
|
scanned
|
file
|
4.9 KB
|
TimerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/timer/TimingWheelTest.java
|
scanned
|
file
|
7.3 KB
|
TimingWheelTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/TranslatedValueMapViewTest.java
|
scanned
|
file
|
4.2 KB
|
TranslatedValueMapViewTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline
|
scanned
|
directory
|
|
timeline
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java
|
scanned
|
file
|
5.5 KB
|
BaseHashTableTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/SnapshotRegistryTest.java
|
scanned
|
file
|
4.7 KB
|
SnapshotRegistryTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/SnapshottableHashTableTest.java
|
scanned
|
file
|
13.6 KB
|
SnapshottableHashTableTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineHashMapTest.java
|
scanned
|
file
|
4.5 KB
|
TimelineHashMapTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineHashSetTest.java
|
scanned
|
file
|
4.5 KB
|
TimelineHashSetTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineIntegerTest.java
|
scanned
|
file
|
3.1 KB
|
TimelineIntegerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineLongTest.java
|
scanned
|
file
|
3.1 KB
|
TimelineLongTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TimelineObjectTest.java
|
scanned
|
file
|
3.2 KB
|
TimelineObjectTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/timeline/TrackingSnapshotRegistry.java
|
scanned
|
file
|
1.7 KB
|
TrackingSnapshotRegistry.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/resources
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/resources/log4j2.yaml
|
scanned
|
file
|
1.1 KB
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src
|
scanned
|
directory
|
|
src
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main
|
scanned
|
directory
|
|
main
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network
|
scanned
|
directory
|
|
network
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/ConnectionQuotaEntity.java
|
scanned
|
file
|
3.3 KB
|
ConnectionQuotaEntity.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/ConnectionThrottledException.java
|
scanned
|
file
|
1.3 KB
|
ConnectionThrottledException.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/metrics
|
scanned
|
directory
|
|
metrics
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/metrics/RequestChannelMetrics.java
|
scanned
|
file
|
2.3 KB
|
RequestChannelMetrics.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/metrics/RequestMetrics.java
|
scanned
|
file
|
10.9 KB
|
RequestMetrics.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java
|
scanned
|
file
|
59.0 KB
|
RequestConvertToJson.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/Session.java
|
scanned
|
file
|
1.3 KB
|
Session.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/SocketServerConfigs.java
|
scanned
|
file
|
16.6 KB
|
SocketServerConfigs.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/network/TooManyConnectionsException.java
|
scanned
|
file
|
1.2 KB
|
TooManyConnectionsException.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/security
|
scanned
|
directory
|
|
security
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/security/authorizer
|
scanned
|
directory
|
|
authorizer
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/security/authorizer/AclEntry.java
|
scanned
|
file
|
3.9 KB
|
AclEntry.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/security/authorizer/AuthorizerUtils.java
|
scanned
|
file
|
1.6 KB
|
AuthorizerUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server
|
scanned
|
directory
|
|
server
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ActionQueue.java
|
scanned
|
file
|
1.1 KB
|
ActionQueue.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ApiVersionManager.java
|
scanned
|
file
|
2.8 KB
|
ApiVersionManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/Assignment.java
|
scanned
|
file
|
2.4 KB
|
Assignment.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/AssignmentsManagerDeadlineFunction.java
|
scanned
|
file
|
3.4 KB
|
AssignmentsManagerDeadlineFunction.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/AssignmentsManager.java
|
scanned
|
file
|
18.6 KB
|
AssignmentsManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/BrokerFeatures.java
|
scanned
|
file
|
7.3 KB
|
BrokerFeatures.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java
|
scanned
|
file
|
32.6 KB
|
ClientMetricsManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config
|
scanned
|
directory
|
|
config
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java
|
scanned
|
file
|
9.8 KB
|
AbstractKafkaConfig.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/ClientQuotaManagerConfig.java
|
scanned
|
file
|
1.6 KB
|
ClientQuotaManagerConfig.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/DynamicProducerStateManagerConfig.java
|
scanned
|
file
|
3.6 KB
|
DynamicProducerStateManagerConfig.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ConfigHelperUtils.java
|
scanned
|
file
|
4.2 KB
|
ConfigHelperUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/KRaftConfigs.java
|
scanned
|
file
|
6.4 KB
|
KRaftConfigs.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/ReplicationConfigs.java
|
scanned
|
file
|
14.9 KB
|
ReplicationConfigs.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/ReplicationQuotaManagerConfig.java
|
scanned
|
file
|
2.1 KB
|
ReplicationQuotaManagerConfig.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/DefaultApiVersionManager.java
|
scanned
|
file
|
4.8 KB
|
DefaultApiVersionManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/DelayedActionQueue.java
|
scanned
|
file
|
2.0 KB
|
DelayedActionQueue.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|