|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/AbstractSaslTest.scala
|
scanned
|
file
|
1.1 KB
|
AbstractSaslTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala
|
scanned
|
file
|
202.3 KB
|
AuthorizerIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/BaseAdminIntegrationTest.scala
|
scanned
|
file
|
11.8 KB
|
BaseAdminIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala
|
scanned
|
file
|
6.9 KB
|
BaseConsumerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala
|
scanned
|
file
|
24.0 KB
|
BaseProducerSendTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala
|
scanned
|
file
|
20.2 KB
|
BaseQuotaTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/ClientIdQuotaTest.scala
|
scanned
|
file
|
2.7 KB
|
ClientIdQuotaTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/ClientOAuthIntegrationTest.scala
|
scanned
|
file
|
14.1 KB
|
ClientOAuthIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala
|
scanned
|
file
|
6.8 KB
|
ConsumerBounceTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala
|
scanned
|
file
|
22.5 KB
|
CustomQuotaCallbackTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala
|
scanned
|
file
|
7.8 KB
|
DelegationTokenEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationWithOwnerTest.scala
|
scanned
|
file
|
6.7 KB
|
DelegationTokenEndToEndAuthorizationWithOwnerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala
|
scanned
|
file
|
28.3 KB
|
EndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/FixedPortTestUtils.scala
|
scanned
|
file
|
2.0 KB
|
FixedPortTestUtils.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/GroupCoordinatorIntegrationTest.scala
|
scanned
|
file
|
14.8 KB
|
GroupCoordinatorIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/GroupEndToEndAuthorizationTest.scala
|
scanned
|
file
|
2.2 KB
|
GroupEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala
|
scanned
|
file
|
14.7 KB
|
IntegrationTestHarness.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/MetricsTest.scala
|
scanned
|
file
|
16.1 KB
|
MetricsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala
|
scanned
|
file
|
237.4 KB
|
PlaintextAdminIntegrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/PlaintextConsumerAssignorsTest.scala
|
scanned
|
file
|
17.3 KB
|
PlaintextConsumerAssignorsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala
|
scanned
|
file
|
3.1 KB
|
PlaintextConsumerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/PlaintextEndToEndAuthorizationTest.scala
|
scanned
|
file
|
4.4 KB
|
PlaintextEndToEndAuthorizationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala
|
scanned
|
file
|
30.2 KB
|
ClientQuotaManagerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ClientRequestQuotaManagerTest.scala
|
scanned
|
file
|
4.5 KB
|
ClientRequestQuotaManagerTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ConsumerGroupDescribeRequestTest.scala
|
scanned
|
file
|
13.3 KB
|
ConsumerGroupDescribeRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala
|
scanned
|
file
|
51.8 KB
|
ConsumerGroupHeartbeatRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ConsumerProtocolMigrationTest.scala
|
scanned
|
file
|
43.9 KB
|
ConsumerProtocolMigrationTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ControllerMutationQuotaTest.scala
|
scanned
|
file
|
19.2 KB
|
ControllerMutationQuotaTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/CreateTopicsRequestTest.scala
|
scanned
|
file
|
7.4 KB
|
CreateTopicsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/DelegationTokenRequestsOnPlainTextTest.scala
|
scanned
|
file
|
3.0 KB
|
DelegationTokenRequestsOnPlainTextTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/DelegationTokenRequestsTest.scala
|
scanned
|
file
|
8.8 KB
|
DelegationTokenRequestsTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/DelegationTokenRequestsWithDisableTokenFeatureTest.scala
|
scanned
|
file
|
3.6 KB
|
DelegationTokenRequestsWithDisableTokenFeatureTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/DeleteGroupsRequestTest.scala
|
scanned
|
file
|
4.2 KB
|
DeleteGroupsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/DeleteRecordsRequestTest.scala
|
scanned
|
file
|
7.6 KB
|
DeleteRecordsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/DeleteTopicsRequestTest.scala
|
scanned
|
file
|
6.1 KB
|
DeleteTopicsRequestTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|