|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/PlaintextProducerSendTest.scala
|
scanned
|
file
|
17.0 KB
|
PlaintextProducerSendTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslClientsWithInvalidCredentialsTest.scala
|
scanned
|
file
|
10.2 KB
|
SaslClientsWithInvalidCredentialsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslEndToEndAuthorizationTest.scala
|
scanned
|
file
|
4.2 KB
|
SaslEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslGssapiSslEndToEndAuthorizationTest.scala
|
scanned
|
file
|
2.3 KB
|
SaslGssapiSslEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslMultiMechanismConsumerTest.scala
|
scanned
|
file
|
4.6 KB
|
SaslMultiMechanismConsumerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslOAuthBearerSslEndToEndAuthorizationTest.scala
|
scanned
|
file
|
1.3 KB
|
SaslOAuthBearerSslEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslPlainSslEndToEndAuthorizationTest.scala
|
scanned
|
file
|
7.5 KB
|
SaslPlainSslEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslPlaintextConsumerTest.scala
|
scanned
|
file
|
1.4 KB
|
SaslPlaintextConsumerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslScramSslEndToEndAuthorizationTest.scala
|
scanned
|
file
|
3.6 KB
|
SaslScramSslEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslSetup.scala
|
scanned
|
file
|
7.8 KB
|
SaslSetup.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslSslAdminIntegrationTest.scala
|
scanned
|
file
|
37.0 KB
|
SaslSslAdminIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SaslSslConsumerTest.scala
|
scanned
|
file
|
1.5 KB
|
SaslSslConsumerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala
|
scanned
|
file
|
17.0 KB
|
SslAdminIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SslConsumerTest.scala
|
scanned
|
file
|
1.1 KB
|
SslConsumerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala
|
scanned
|
file
|
4.6 KB
|
SslEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/SslProducerSendTest.scala
|
scanned
|
file
|
1.1 KB
|
SslProducerSendTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/TransactionsBounceTest.scala
|
scanned
|
file
|
10.0 KB
|
TransactionsBounceTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
|
scanned
|
file
|
46.8 KB
|
TransactionsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/UserClientIdQuotaTest.scala
|
scanned
|
file
|
3.3 KB
|
UserClientIdQuotaTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/UserQuotaTest.scala
|
scanned
|
file
|
3.2 KB
|
UserQuotaTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/coordinator/transaction/ProducerIntegrationTest.scala
|
scanned
|
file
|
10.2 KB
|
ProducerIntegrationTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/network/DynamicConnectionQuotaTest.scala
|
scanned
|
file
|
19.7 KB
|
DynamicConnectionQuotaTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/network/DynamicNumNetworkThreadsTest.scala
|
scanned
|
file
|
4.9 KB
|
DynamicNumNetworkThreadsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/DelayedFetchTest.scala
|
scanned
|
file
|
11.1 KB
|
DelayedFetchTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala
|
scanned
|
file
|
87.1 KB
|
DynamicBrokerReconfigurationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/FetchFromFollowerIntegrationTest.scala
|
scanned
|
file
|
12.5 KB
|
FetchFromFollowerIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/GssapiAuthenticationTest.scala
|
scanned
|
file
|
13.4 KB
|
GssapiAuthenticationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/KRaftClusterTest.scala
|
scanned
|
file
|
59.9 KB
|
KRaftClusterTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/MultipleListenersWithAdditionalJaasContextTest.scala
|
scanned
|
file
|
1.8 KB
|
MultipleListenersWithAdditionalJaasContextTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/MultipleListenersWithDefaultJaasContextTest.scala
|
scanned
|
file
|
1.3 KB
|
MultipleListenersWithDefaultJaasContextTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/MultipleListenersWithSameSecurityProtocolBaseTest.scala
|
scanned
|
file
|
10.2 KB
|
MultipleListenersWithSameSecurityProtocolBaseTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala
|
scanned
|
file
|
16.0 KB
|
QuorumTestHarness.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/server/RaftClusterSnapshotTest.scala
|
scanned
|
file
|
3.7 KB
|
RaftClusterSnapshotTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/raft/DefaultExternalKRaftMetricsTest.scala
|
scanned
|
file
|
2.2 KB
|
DefaultExternalKRaftMetricsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/raft/KafkaMetadataLogTest.scala
|
scanned
|
file
|
39.4 KB
|
KafkaMetadataLogTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/server/KafkaRequestHandlerTest.scala
|
scanned
|
file
|
29.0 KB
|
KafkaRequestHandlerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/server/LocalLeaderEndPointTest.scala
|
scanned
|
file
|
10.8 KB
|
LocalLeaderEndPointTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/server/metadata/ClientQuotaMetadataManagerTest.scala
|
scanned
|
file
|
3.9 KB
|
ClientQuotaMetadataManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/server/NodeToControllerRequestThreadTest.scala
|
scanned
|
file
|
18.2 KB
|
NodeToControllerRequestThreadTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/server/RemoteLeaderEndPointTest.scala
|
scanned
|
file
|
7.4 KB
|
RemoteLeaderEndPointTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/utils/LoggingTest.scala
|
scanned
|
file
|
3.0 KB
|
LoggingTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/kafka/utils/TestInfoUtils.scala
|
scanned
|
file
|
1.9 KB
|
TestInfoUtils.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/admin/AddPartitionsTest.scala
|
scanned
|
file
|
9.9 KB
|
AddPartitionsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/cluster/AbstractPartitionTest.scala
|
scanned
|
file
|
6.6 KB
|
AbstractPartitionTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/cluster/AssignmentStateTest.scala
|
scanned
|
file
|
5.0 KB
|
AssignmentStateTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/cluster/PartitionLockTest.scala
|
scanned
|
file
|
17.8 KB
|
PartitionLockTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/cluster/PartitionTest.scala
|
scanned
|
file
|
166.0 KB
|
PartitionTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/coordinator/AbstractCoordinatorConcurrencyTest.scala
|
scanned
|
file
|
12.4 KB
|
AbstractCoordinatorConcurrencyTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/coordinator/group/CoordinatorPartitionWriterTest.scala
|
scanned
|
file
|
14.9 KB
|
CoordinatorPartitionWriterTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorConcurrencyTest.scala
|
scanned
|
file
|
29.8 KB
|
TransactionCoordinatorConcurrencyTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/coordinator/transaction/TransactionCoordinatorTest.scala
|
scanned
|
file
|
103.9 KB
|
TransactionCoordinatorTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala
|
scanned
|
file
|
28.7 KB
|
TransactionMarkerChannelManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandlerTest.scala
|
scanned
|
file
|
9.4 KB
|
TransactionMarkerRequestCompletionHandlerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMetadataTest.scala
|
scanned
|
file
|
27.8 KB
|
TransactionMetadataTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/coordinator/transaction/TransactionStateManagerTest.scala
|
scanned
|
file
|
66.7 KB
|
TransactionStateManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/docker/KafkaDockerWrapperTest.scala
|
scanned
|
file
|
18.8 KB
|
KafkaDockerWrapperTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala
|
scanned
|
file
|
13.3 KB
|
KafkaServerTestHarness.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/integration/UncleanLeaderElectionTest.scala
|
scanned
|
file
|
20.5 KB
|
UncleanLeaderElectionTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/KafkaConfigTest.scala
|
scanned
|
file
|
17.2 KB
|
KafkaConfigTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/AbstractLogCleanerIntegrationTest.scala
|
scanned
|
file
|
7.0 KB
|
AbstractLogCleanerIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala
|
scanned
|
file
|
9.8 KB
|
LogCleanerIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogCleanerLagIntegrationTest.scala
|
scanned
|
file
|
5.6 KB
|
LogCleanerLagIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala
|
scanned
|
file
|
41.6 KB
|
LogCleanerManagerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogCleanerParameterizedIntegrationTest.scala
|
scanned
|
file
|
18.9 KB
|
LogCleanerParameterizedIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogCleanerTest.scala
|
scanned
|
file
|
108.4 KB
|
LogCleanerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogConfigTest.scala
|
scanned
|
file
|
21.6 KB
|
LogConfigTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogLoaderTest.scala
|
scanned
|
file
|
81.0 KB
|
LogLoaderTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogManagerTest.scala
|
scanned
|
file
|
56.4 KB
|
LogManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/LogTestUtils.scala
|
scanned
|
file
|
15.1 KB
|
LogTestUtils.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala
|
scanned
|
file
|
236.0 KB
|
UnifiedLogTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/metrics/KafkaMetricsGroupTest.scala
|
scanned
|
file
|
2.9 KB
|
KafkaMetricsGroupTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/metrics/MetricsTest.scala
|
scanned
|
file
|
11.3 KB
|
MetricsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala
|
scanned
|
file
|
47.0 KB
|
ConnectionQuotasTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/network/ProcessorTest.scala
|
scanned
|
file
|
5.1 KB
|
ProcessorTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/network/RequestChannelTest.scala
|
scanned
|
file
|
15.9 KB
|
RequestChannelTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/network/RequestConvertToJsonTest.scala
|
scanned
|
file
|
6.1 KB
|
RequestConvertToJsonTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
|
scanned
|
file
|
108.0 KB
|
SocketServerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/raft/RaftManagerTest.scala
|
scanned
|
file
|
8.2 KB
|
RaftManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/security/authorizer/AuthorizerTest.scala
|
scanned
|
file
|
32.5 KB
|
AuthorizerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/security/authorizer/BaseAuthorizerTest.scala
|
scanned
|
file
|
19.7 KB
|
BaseAuthorizerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala
|
scanned
|
file
|
7.1 KB
|
AbstractApiVersionsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AbstractCreateTopicsRequestTest.scala
|
scanned
|
file
|
8.1 KB
|
AbstractCreateTopicsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AbstractFetcherManagerTest.scala
|
scanned
|
file
|
16.7 KB
|
AbstractFetcherManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AbstractFetcherThreadTest.scala
|
scanned
|
file
|
78.8 KB
|
AbstractFetcherThreadTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AbstractMetadataRequestTest.scala
|
scanned
|
file
|
2.7 KB
|
AbstractMetadataRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AddPartitionsToTxnRequestServerTest.scala
|
scanned
|
file
|
9.3 KB
|
AddPartitionsToTxnRequestServerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AllocateProducerIdsRequestTest.scala
|
scanned
|
file
|
3.6 KB
|
AllocateProducerIdsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AlterPartitionManagerTest.scala
|
scanned
|
file
|
22.7 KB
|
AlterPartitionManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AlterReplicaLogDirsRequestTest.scala
|
scanned
|
file
|
10.2 KB
|
AlterReplicaLogDirsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestNotAuthorizedTest.scala
|
scanned
|
file
|
4.5 KB
|
AlterUserScramCredentialsRequestNotAuthorizedTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AlterUserScramCredentialsRequestTest.scala
|
scanned
|
file
|
27.4 KB
|
AlterUserScramCredentialsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala
|
scanned
|
file
|
5.5 KB
|
ApiVersionsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ApiVersionsResponseIntegrationTest.scala
|
scanned
|
file
|
2.8 KB
|
ApiVersionsResponseIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AuthHelperTest.scala
|
scanned
|
file
|
11.3 KB
|
AuthHelperTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/AutoTopicCreationManagerTest.scala
|
scanned
|
file
|
52.4 KB
|
AutoTopicCreationManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/BaseClientQuotaManagerTest.scala
|
scanned
|
file
|
4.0 KB
|
BaseClientQuotaManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/BaseFetchRequestTest.scala
|
scanned
|
file
|
4.5 KB
|
BaseFetchRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/BaseRequestTest.scala
|
scanned
|
file
|
6.0 KB
|
BaseRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/BrokerLifecycleManagerTest.scala
|
scanned
|
file
|
13.3 KB
|
BrokerLifecycleManagerTest.scala
|
.scala
|
Scala
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/BrokerMetricNamesTest.scala
|
scanned
|
file
|
1.7 KB
|
BrokerMetricNamesTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|