|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/CommittedPartitionState.java
|
scanned
|
file
|
1.3 KB
|
CommittedPartitionState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/PartitionFetchState.java
|
scanned
|
file
|
3.5 KB
|
PartitionFetchState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/OngoingReassignmentState.java
|
scanned
|
file
|
1.6 KB
|
OngoingReassignmentState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/PartitionListener.java
|
scanned
|
file
|
2.6 KB
|
PartitionListener.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/PartitionState.java
|
scanned
|
file
|
1.7 KB
|
PartitionState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/PendingExpandIsr.java
|
scanned
|
file
|
2.4 KB
|
PendingExpandIsr.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/PendingPartitionChange.java
|
scanned
|
file
|
1.3 KB
|
PendingPartitionChange.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/PendingShrinkIsr.java
|
scanned
|
file
|
2.3 KB
|
PendingShrinkIsr.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/SimpleAssignmentState.java
|
scanned
|
file
|
1.2 KB
|
SimpleAssignmentState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ProcessRole.java
|
scanned
|
file
|
1.1 KB
|
ProcessRole.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/purgatory/DelayedDeleteRecords.java
|
scanned
|
file
|
5.1 KB
|
DelayedDeleteRecords.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/purgatory/DelayedFuture.java
|
scanned
|
file
|
3.2 KB
|
DelayedFuture.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/purgatory/DelayedFuturePurgatory.java
|
scanned
|
file
|
2.7 KB
|
DelayedFuturePurgatory.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/purgatory/DeleteRecordsPartitionStatus.java
|
scanned
|
file
|
2.0 KB
|
DeleteRecordsPartitionStatus.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/AbstractControllerMutationQuota.java
|
scanned
|
file
|
2.3 KB
|
AbstractControllerMutationQuota.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/ClientQuotaManager.java
|
scanned
|
file
|
37.7 KB
|
ClientQuotaManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/ClientSensors.java
|
scanned
|
file
|
1.5 KB
|
ClientSensors.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/ControllerMutationQuota.java
|
scanned
|
file
|
1.5 KB
|
ControllerMutationQuota.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/ControllerMutationQuotaManager.java
|
scanned
|
file
|
8.1 KB
|
ControllerMutationQuotaManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/PermissiveControllerMutationQuota.java
|
scanned
|
file
|
2.3 KB
|
PermissiveControllerMutationQuota.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/StrictControllerMutationQuota.java
|
scanned
|
file
|
2.7 KB
|
StrictControllerMutationQuota.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/ThrottleCallback.java
|
scanned
|
file
|
931 bytes
|
ThrottleCallback.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/ThrottledChannel.java
|
scanned
|
file
|
2.6 KB
|
ThrottledChannel.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ReplicaFetch.java
|
scanned
|
file
|
1.1 KB
|
ReplicaFetch.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/replica/Replica.java
|
scanned
|
file
|
7.8 KB
|
Replica.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/replica/ReplicaState.java
|
scanned
|
file
|
3.3 KB
|
ReplicaState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ReplicaState.java
|
scanned
|
file
|
1.1 KB
|
ReplicaState.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ResultWithPartitions.java
|
scanned
|
file
|
1016 bytes
|
ResultWithPartitions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ServerSocketFactory.java
|
scanned
|
file
|
2.5 KB
|
ServerSocketFactory.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/acknowledge/ShareAcknowledgementBatch.java
|
scanned
|
file
|
1.8 KB
|
ShareAcknowledgementBatch.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/CachedSharePartition.java
|
scanned
|
file
|
5.7 KB
|
CachedSharePartition.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/context/FinalContext.java
|
scanned
|
file
|
2.3 KB
|
FinalContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/context/ShareFetchContext.java
|
scanned
|
file
|
3.6 KB
|
ShareFetchContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/context/ShareSessionContext.java
|
scanned
|
file
|
10.7 KB
|
ShareSessionContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/ErroneousAndValidPartitionData.java
|
scanned
|
file
|
2.6 KB
|
ErroneousAndValidPartitionData.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/AcquisitionLockTimeoutHandler.java
|
scanned
|
file
|
1.5 KB
|
AcquisitionLockTimeoutHandler.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/AcquisitionLockTimerTask.java
|
scanned
|
file
|
2.9 KB
|
AcquisitionLockTimerTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchGroupKey.java
|
scanned
|
file
|
2.3 KB
|
DelayedShareFetchGroupKey.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchKey.java
|
scanned
|
file
|
1.0 KB
|
DelayedShareFetchKey.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchPartitionKey.java
|
scanned
|
file
|
2.2 KB
|
DelayedShareFetchPartitionKey.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/DeliveryCountOps.java
|
scanned
|
file
|
1.0 KB
|
DeliveryCountOps.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/InFlightBatch.java
|
scanned
|
file
|
12.7 KB
|
InFlightBatch.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/InFlightState.java
|
scanned
|
file
|
12.3 KB
|
InFlightState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategy.java
|
scanned
|
file
|
6.3 KB
|
PartitionMaxBytesStrategy.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/PartitionRotateStrategy.java
|
scanned
|
file
|
3.6 KB
|
PartitionRotateStrategy.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/RecordState.java
|
scanned
|
file
|
3.0 KB
|
RecordState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/ShareAcquiredRecords.java
|
scanned
|
file
|
2.1 KB
|
ShareAcquiredRecords.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/ShareFetch.java
|
scanned
|
file
|
8.6 KB
|
ShareFetch.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/ShareFetchPartitionData.java
|
scanned
|
file
|
1.2 KB
|
ShareFetchPartitionData.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/metrics/ShareGroupMetrics.java
|
scanned
|
file
|
5.8 KB
|
ShareGroupMetrics.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/metrics/SharePartitionMetrics.java
|
scanned
|
file
|
5.4 KB
|
SharePartitionMetrics.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java
|
scanned
|
file
|
13.0 KB
|
ShareSessionCache.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/session/ShareSession.java
|
scanned
|
file
|
5.7 KB
|
ShareSession.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/session/ShareSessionKey.java
|
scanned
|
file
|
1.0 KB
|
ShareSessionKey.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/ShareGroupListener.java
|
scanned
|
file
|
1.3 KB
|
ShareGroupListener.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/SimpleApiVersionManager.java
|
scanned
|
file
|
3.8 KB
|
SimpleApiVersionManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/transaction/AddPartitionsToTxnManager.java
|
scanned
|
file
|
19.3 KB
|
AddPartitionsToTxnManager.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java
|
scanned
|
file
|
11.9 KB
|
EndToEndClusterIdTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/network/RequestConvertToJsonTest.java
|
scanned
|
file
|
5.9 KB
|
RequestConvertToJsonTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/network/SocketServerConfigsTest.java
|
scanned
|
file
|
4.6 KB
|
SocketServerConfigsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/security/authorizer/AuthorizerUtilsTest.java
|
scanned
|
file
|
5.8 KB
|
AuthorizerUtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/AssignmentsManagerDeadlineFunctionTest.java
|
scanned
|
file
|
3.3 KB
|
AssignmentsManagerDeadlineFunctionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/AssignmentsManagerTest.java
|
scanned
|
file
|
24.3 KB
|
AssignmentsManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/AssignmentTest.java
|
scanned
|
file
|
4.4 KB
|
AssignmentTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/BootstrapControllersIntegrationTest.java
|
scanned
|
file
|
19.0 KB
|
BootstrapControllersIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/BrokerFeaturesTest.java
|
scanned
|
file
|
5.7 KB
|
BrokerFeaturesTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/BrokerRegistrationRequestTest.java
|
scanned
|
file
|
10.1 KB
|
BrokerRegistrationRequestTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/ClientMetricsManagerTest.java
|
scanned
|
file
|
78.7 KB
|
ClientMetricsManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/config/DelegationTokenManagerConfigsTest.java
|
scanned
|
file
|
3.9 KB
|
DelegationTokenManagerConfigsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/config/MinInSyncReplicasConfigTest.java
|
scanned
|
file
|
1.4 KB
|
MinInSyncReplicasConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/EligibleLeaderReplicasIntegrationTest.java
|
scanned
|
file
|
21.6 KB
|
EligibleLeaderReplicasIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/KRaftClusterTest.java
|
scanned
|
file
|
17.7 KB
|
KRaftClusterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/LogManagerIntegrationTest.java
|
scanned
|
file
|
8.7 KB
|
LogManagerIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/BrokerServerMetricsTest.java
|
scanned
|
file
|
7.1 KB
|
BrokerServerMetricsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsInstanceMetadataTest.java
|
scanned
|
file
|
7.2 KB
|
ClientMetricsInstanceMetadataTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsInstanceTest.java
|
scanned
|
file
|
4.3 KB
|
ClientMetricsInstanceTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsTelemetryPluginTest.java
|
scanned
|
file
|
6.7 KB
|
ClientMetricsTelemetryPluginTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientMetricsTestUtils.java
|
scanned
|
file
|
6.5 KB
|
ClientMetricsTestUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ClientTelemetryTest.java
|
scanned
|
file
|
3.9 KB
|
ClientTelemetryTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/ForwardingManagerMetricsTest.java
|
scanned
|
file
|
6.3 KB
|
ForwardingManagerMetricsTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/LinuxIoMetricsCollectorTest.java
|
scanned
|
file
|
3.5 KB
|
LinuxIoMetricsCollectorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/metrics/NodeMetricsTest.java
|
scanned
|
file
|
4.4 KB
|
NodeMetricsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/MonitorablePluginsIntegrationTest.java
|
scanned
|
file
|
7.3 KB
|
MonitorablePluginsIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/purgatory/DelayedFutureTest.java
|
scanned
|
file
|
5.9 KB
|
DelayedFutureTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/quota/ClientQuotasRequestTest.java
|
scanned
|
file
|
33.4 KB
|
ClientQuotasRequestTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/quota/ClientSensorsTest.java
|
scanned
|
file
|
4.0 KB
|
ClientSensorsTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/quota/ThrottledChannelTest.java
|
scanned
|
file
|
2.1 KB
|
ThrottledChannelTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/ReconfigurableQuorumIntegrationTest.java
|
scanned
|
file
|
14.8 KB
|
ReconfigurableQuorumIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/replica/ReplicaTest.java
|
scanned
|
file
|
8.9 KB
|
ReplicaTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/CachedSharePartitionTest.java
|
scanned
|
file
|
3.3 KB
|
CachedSharePartitionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/DelayedShareFetchKeyTest.java
|
scanned
|
file
|
2.7 KB
|
DelayedShareFetchKeyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/PartitionMaxBytesStrategyTest.java
|
scanned
|
file
|
5.0 KB
|
PartitionMaxBytesStrategyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/PartitionRotateStrategyTest.java
|
scanned
|
file
|
4.1 KB
|
PartitionRotateStrategyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/RecordStateTest.java
|
scanned
|
file
|
3.9 KB
|
RecordStateTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTest.java
|
scanned
|
file
|
14.2 KB
|
ShareFetchTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/fetch/ShareFetchTestUtils.java
|
scanned
|
file
|
6.0 KB
|
ShareFetchTestUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/session/ShareSessionCacheTest.java
|
scanned
|
file
|
15.6 KB
|
ShareSessionCacheTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/session/ShareSessionKeyTest.java
|
scanned
|
file
|
1.6 KB
|
ShareSessionKeyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/share/session/ShareSessionTest.java
|
scanned
|
file
|
2.0 KB
|
ShareSessionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/server/src/test/java/org/apache/kafka/server/transaction/AddPartitionsToTxnManagerTest.java
|
scanned
|
file
|
28.4 KB
|
AddPartitionsToTxnManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|