|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/RecordsBatchReaderTest.java
|
scanned
|
file
|
5.7 KB
|
RecordsBatchReaderTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/RecordsIteratorTest.java
|
scanned
|
file
|
19.4 KB
|
RecordsIteratorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/ThresholdPurgatoryTest.java
|
scanned
|
file
|
6.4 KB
|
ThresholdPurgatoryTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/TreeMapLogHistoryTest.java
|
scanned
|
file
|
4.5 KB
|
TreeMapLogHistoryTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/internals/VoterSetHistoryTest.java
|
scanned
|
file
|
11.2 KB
|
VoterSetHistoryTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaNetworkChannelTest.java
|
scanned
|
file
|
17.7 KB
|
KafkaNetworkChannelTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientAutoJoinTest.java
|
scanned
|
file
|
12.7 KB
|
KafkaRaftClientAutoJoinTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientClusterAuthTest.java
|
scanned
|
file
|
6.3 KB
|
KafkaRaftClientClusterAuthTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientDriverTest.java
|
scanned
|
file
|
3.5 KB
|
KafkaRaftClientDriverTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientFetchTest.java
|
scanned
|
file
|
17.8 KB
|
KafkaRaftClientFetchTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientPreVoteTest.java
|
scanned
|
file
|
50.8 KB
|
KafkaRaftClientPreVoteTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientReconfigTest.java
|
scanned
|
file
|
118.7 KB
|
KafkaRaftClientReconfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java
|
scanned
|
file
|
92.6 KB
|
KafkaRaftClientSnapshotTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java
|
scanned
|
file
|
203.5 KB
|
KafkaRaftClientTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/LeaderAndEpochTest.java
|
scanned
|
file
|
1.8 KB
|
LeaderAndEpochTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/LeaderStateTest.java
|
scanned
|
file
|
37.6 KB
|
LeaderStateTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockableRandom.java
|
scanned
|
file
|
1.7 KB
|
MockableRandom.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockExpirationService.java
|
scanned
|
file
|
2.8 KB
|
MockExpirationService.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockExpirationServiceTest.java
|
scanned
|
file
|
2.1 KB
|
MockExpirationServiceTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockLog.java
|
scanned
|
file
|
24.3 KB
|
MockLog.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockLogTest.java
|
scanned
|
file
|
40.1 KB
|
MockLogTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/MockMessageQueue.java
|
scanned
|
file
|
2.1 KB
|
MockMessageQueue.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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
|
|
|