|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockNetworkChannel.java
|
scanned
|
file
|
3.1 KB
|
MockNetworkChannel.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockQuorumStateStore.java
|
scanned
|
file
|
1.7 KB
|
MockQuorumStateStore.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ProspectiveStateTest.java
|
scanned
|
file
|
19.8 KB
|
ProspectiveStateTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/QuorumConfigTest.java
|
scanned
|
file
|
2.6 KB
|
QuorumConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java
|
scanned
|
file
|
109.2 KB
|
QuorumStateTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java
|
scanned
|
file
|
89.7 KB
|
RaftClientTestContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java
|
scanned
|
file
|
57.3 KB
|
RaftEventSimulationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/RaftUtilTest.java
|
scanned
|
file
|
38.4 KB
|
RaftUtilTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ReplicatedCounter.java
|
scanned
|
file
|
7.7 KB
|
ReplicatedCounter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/RequestManagerTest.java
|
scanned
|
file
|
11.7 KB
|
RequestManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ResignedStateTest.java
|
scanned
|
file
|
4.9 KB
|
ResignedStateTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/UnattachedStateTest.java
|
scanned
|
file
|
8.8 KB
|
UnattachedStateTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/ValidOffsetAndEpochTest.java
|
scanned
|
file
|
2.0 KB
|
ValidOffsetAndEpochTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/VoterSetTest.java
|
scanned
|
file
|
16.8 KB
|
VoterSetTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/FileRawSnapshotTest.java
|
scanned
|
file
|
13.5 KB
|
FileRawSnapshotTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/MockRawSnapshotReader.java
|
scanned
|
file
|
2.1 KB
|
MockRawSnapshotReader.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/MockRawSnapshotWriter.java
|
scanned
|
file
|
3.0 KB
|
MockRawSnapshotWriter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriterTest.java
|
scanned
|
file
|
3.8 KB
|
NotifyingRawSnapshotWriterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/RecordsSnapshotWriterTest.java
|
scanned
|
file
|
9.9 KB
|
RecordsSnapshotWriterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/SnapshotsTest.java
|
scanned
|
file
|
5.2 KB
|
SnapshotsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/snapshot/SnapshotWriterReaderTest.java
|
scanned
|
file
|
11.2 KB
|
SnapshotWriterReaderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/resources/log4j2.yaml
|
scanned
|
file
|
1.2 KB
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/git.py
|
scanned
|
file
|
3.9 KB
|
git.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/gpg.py
|
scanned
|
file
|
2.6 KB
|
gpg.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/notes.py
|
scanned
|
file
|
6.3 KB
|
notes.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/preferences.py
|
scanned
|
file
|
2.2 KB
|
preferences.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/release.py
|
scanned
|
file
|
17.0 KB
|
release.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/runtime.py
|
scanned
|
file
|
3.9 KB
|
runtime.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/svn.py
|
scanned
|
file
|
2.4 KB
|
svn.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/templates.py
|
scanned
|
file
|
13.0 KB
|
templates.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/textfiles.py
|
scanned
|
file
|
2.0 KB
|
textfiles.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/common/ClientIdAndBroker.java
|
scanned
|
file
|
1.4 KB
|
ClientIdAndBroker.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/main/java/org/apache/kafka/common/DirectoryId.java
|
scanned
|
file
|
5.6 KB
|
DirectoryId.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/main/java/org/apache/kafka/config/BrokerReconfigurable.java
|
scanned
|
file
|
2.5 KB
|
BrokerReconfigurable.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/main/java/org/apache/kafka/deferred/DeferredEvent.java
|
scanned
|
file
|
1.1 KB
|
DeferredEvent.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/main/java/org/apache/kafka/deferred/DeferredEventQueue.java
|
scanned
|
file
|
4.4 KB
|
DeferredEventQueue.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/main/java/org/apache/kafka/logger/StateChangeLogger.java
|
scanned
|
file
|
1.8 KB
|
StateChangeLogger.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/main/java/org/apache/kafka/metadata/AssignmentsHelper.java
|
scanned
|
file
|
6.7 KB
|
AssignmentsHelper.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/main/java/org/apache/kafka/queue/EventQueue.java
|
scanned
|
file
|
8.5 KB
|
EventQueue.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/main/java/org/apache/kafka/queue/KafkaEventQueue.java
|
scanned
|
file
|
20.0 KB
|
KafkaEventQueue.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/main/java/org/apache/kafka/security/CredentialProvider.java
|
scanned
|
file
|
2.2 KB
|
CredentialProvider.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/main/java/org/apache/kafka/security/DelegationTokenManager.java
|
scanned
|
file
|
5.3 KB
|
DelegationTokenManager.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/main/java/org/apache/kafka/server/common/ApiMessageAndVersion.java
|
scanned
|
file
|
1.9 KB
|
ApiMessageAndVersion.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/main/java/org/apache/kafka/server/common/CheckpointFile.java
|
scanned
|
file
|
7.7 KB
|
CheckpointFile.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/main/java/org/apache/kafka/server/common/ControllerRequestCompletionHandler.java
|
scanned
|
file
|
1.2 KB
|
ControllerRequestCompletionHandler.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/main/java/org/apache/kafka/server/common/DirectoryEventHandler.java
|
scanned
|
file
|
1.8 KB
|
DirectoryEventHandler.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/main/java/org/apache/kafka/server/common/EligibleLeaderReplicasVersion.java
|
scanned
|
file
|
2.5 KB
|
EligibleLeaderReplicasVersion.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/main/java/org/apache/kafka/server/common/Feature.java
|
scanned
|
file
|
17.7 KB
|
Feature.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/main/java/org/apache/kafka/server/common/FeatureVersion.java
|
scanned
|
file
|
2.7 KB
|
FeatureVersion.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/main/java/org/apache/kafka/server/common/FinalizedFeatures.java
|
scanned
|
file
|
2.5 KB
|
FinalizedFeatures.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/main/java/org/apache/kafka/server/common/GroupVersion.java
|
scanned
|
file
|
2.5 KB
|
GroupVersion.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/main/java/org/apache/kafka/server/common/KRaftVersion.java
|
scanned
|
file
|
3.4 KB
|
KRaftVersion.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/main/java/org/apache/kafka/server/common/MetadataVersion.java
|
scanned
|
file
|
15.4 KB
|
MetadataVersion.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/main/java/org/apache/kafka/server/common/NodeToControllerChannelManager.java
|
scanned
|
file
|
1.3 KB
|
NodeToControllerChannelManager.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/main/java/org/apache/kafka/server/common/OffsetAndEpoch.java
|
scanned
|
file
|
1.1 KB
|
OffsetAndEpoch.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/main/java/org/apache/kafka/server/common/ProducerIdsBlock.java
|
scanned
|
file
|
3.5 KB
|
ProducerIdsBlock.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/main/java/org/apache/kafka/server/common/RequestLocal.java
|
scanned
|
file
|
2.4 KB
|
RequestLocal.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/main/java/org/apache/kafka/server/common/serialization/AbstractApiMessageSerde.java
|
scanned
|
file
|
5.4 KB
|
AbstractApiMessageSerde.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/common/serialization/BytesApiMessageSerde.java
|
scanned
|
file
|
3.0 KB
|
BytesApiMessageSerde.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/main/java/org/apache/kafka/server/common/serialization/MetadataParseException.java
|
scanned
|
file
|
1.3 KB
|
MetadataParseException.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/main/java/org/apache/kafka/server/common/serialization/RecordSerde.java
|
scanned
|
file
|
2.4 KB
|
RecordSerde.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/main/java/org/apache/kafka/server/common/ShareVersion.java
|
scanned
|
file
|
2.5 KB
|
ShareVersion.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/main/java/org/apache/kafka/server/common/StopPartition.java
|
scanned
|
file
|
2.6 KB
|
StopPartition.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/main/java/org/apache/kafka/server/common/StreamsVersion.java
|
scanned
|
file
|
2.5 KB
|
StreamsVersion.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/main/java/org/apache/kafka/server/common/TestFeatureVersion.java
|
scanned
|
file
|
2.3 KB
|
TestFeatureVersion.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/main/java/org/apache/kafka/server/common/TopicIdPartition.java
|
scanned
|
file
|
1.2 KB
|
TopicIdPartition.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/main/java/org/apache/kafka/server/common/TransactionVersion.java
|
scanned
|
file
|
3.7 KB
|
TransactionVersion.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/main/java/org/apache/kafka/server/common/UnitTestFeatureVersion.java
|
scanned
|
file
|
11.7 KB
|
UnitTestFeatureVersion.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/main/java/org/apache/kafka/server/config/ConfigSynonym.java
|
scanned
|
file
|
2.7 KB
|
ConfigSynonym.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/config/ConfigType.java
|
scanned
|
file
|
1.2 KB
|
ConfigType.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/main/java/org/apache/kafka/server/config/DelegationTokenManagerConfigs.java
|
scanned
|
file
|
5.3 KB
|
DelegationTokenManagerConfigs.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/main/java/org/apache/kafka/server/config/QuotaConfig.java
|
scanned
|
file
|
16.1 KB
|
QuotaConfig.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/main/java/org/apache/kafka/server/config/ServerConfigs.java
|
scanned
|
file
|
13.3 KB
|
ServerConfigs.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/main/java/org/apache/kafka/server/config/ServerLogConfigs.java
|
scanned
|
file
|
13.9 KB
|
ServerLogConfigs.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/main/java/org/apache/kafka/server/config/ServerTopicConfigSynonyms.java
|
scanned
|
file
|
7.4 KB
|
ServerTopicConfigSynonyms.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/main/java/org/apache/kafka/server/fault/FaultHandlerException.java
|
scanned
|
file
|
1.5 KB
|
FaultHandlerException.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/main/java/org/apache/kafka/server/fault/FaultHandler.java
|
scanned
|
file
|
1.5 KB
|
FaultHandler.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/main/java/org/apache/kafka/server/fault/LoggingFaultHandler.java
|
scanned
|
file
|
1.8 KB
|
LoggingFaultHandler.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/main/java/org/apache/kafka/server/fault/ProcessTerminatingFaultHandler.java
|
scanned
|
file
|
3.2 KB
|
ProcessTerminatingFaultHandler.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/main/java/org/apache/kafka/server/immutable/ImmutableMap.java
|
scanned
|
file
|
2.2 KB
|
ImmutableMap.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/main/java/org/apache/kafka/server/immutable/ImmutableNavigableSet.java
|
scanned
|
file
|
2.2 KB
|
ImmutableNavigableSet.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/main/java/org/apache/kafka/server/immutable/ImmutableSet.java
|
scanned
|
file
|
2.0 KB
|
ImmutableSet.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/main/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableMap.java
|
scanned
|
file
|
6.8 KB
|
PCollectionsImmutableMap.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/main/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableNavigableSet.java
|
scanned
|
file
|
7.6 KB
|
PCollectionsImmutableNavigableSet.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/main/java/org/apache/kafka/server/immutable/pcollections/PCollectionsImmutableSet.java
|
scanned
|
file
|
5.2 KB
|
PCollectionsImmutableSet.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/main/java/org/apache/kafka/server/metrics/FilteringJmxReporter.java
|
scanned
|
file
|
2.0 KB
|
FilteringJmxReporter.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/main/java/org/apache/kafka/server/metrics/KafkaMetricsGroup.java
|
scanned
|
file
|
6.7 KB
|
KafkaMetricsGroup.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/main/java/org/apache/kafka/server/metrics/KafkaYammerMetrics.java
|
scanned
|
file
|
6.3 KB
|
KafkaYammerMetrics.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/main/java/org/apache/kafka/server/metrics/TimeRatio.java
|
scanned
|
file
|
3.7 KB
|
TimeRatio.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/main/java/org/apache/kafka/server/mutable/BoundedList.java
|
scanned
|
file
|
6.1 KB
|
BoundedList.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/main/java/org/apache/kafka/server/mutable/BoundedListTooLongException.java
|
scanned
|
file
|
1.2 KB
|
BoundedListTooLongException.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/main/java/org/apache/kafka/server/network/BrokerEndPoint.java
|
scanned
|
file
|
1.3 KB
|
BrokerEndPoint.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/main/java/org/apache/kafka/server/network/ConnectionDisconnectListener.java
|
scanned
|
file
|
1.5 KB
|
ConnectionDisconnectListener.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/main/java/org/apache/kafka/server/network/EndpointReadyFutures.java
|
scanned
|
file
|
8.2 KB
|
EndpointReadyFutures.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/main/java/org/apache/kafka/server/network/KafkaAuthorizerServerInfo.java
|
scanned
|
file
|
3.6 KB
|
KafkaAuthorizerServerInfo.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/main/java/org/apache/kafka/server/purgatory/DelayedOperation.java
|
scanned
|
file
|
5.3 KB
|
DelayedOperation.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/main/java/org/apache/kafka/server/purgatory/DelayedOperationKey.java
|
scanned
|
file
|
969 bytes
|
DelayedOperationKey.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/main/java/org/apache/kafka/server/purgatory/DelayedOperationPurgatory.java
|
scanned
|
file
|
16.8 KB
|
DelayedOperationPurgatory.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/main/java/org/apache/kafka/server/purgatory/TopicPartitionOperationKey.java
|
scanned
|
file
|
2.0 KB
|
TopicPartitionOperationKey.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/main/java/org/apache/kafka/server/quota/QuotaType.java
|
scanned
|
file
|
1.8 KB
|
QuotaType.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|