|
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
|
scanned
|
directory
|
|
utils
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
unit
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/admin
|
scanned
|
directory
|
|
admin
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
cluster
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
coordinator
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
group
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
transaction
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
docker
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
integration
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
log
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
metrics
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
network
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
raft
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
security
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/security/authorizer
|
scanned
|
directory
|
|
authorizer
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
server
|
|
|
|
|
|
|
|
|
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
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/ConfigAdminManagerTest.scala
|
scanned
|
file
|
19.4 KB
|
ConfigAdminManagerTest.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/ConsumerGroupDescribeRequestTest.scala
|
scanned
|
file
|
13.3 KB
|
ConsumerGroupDescribeRequestTest.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/ConsumerGroupHeartbeatRequestTest.scala
|
scanned
|
file
|
51.8 KB
|
ConsumerGroupHeartbeatRequestTest.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/ConsumerProtocolMigrationTest.scala
|
scanned
|
file
|
43.9 KB
|
ConsumerProtocolMigrationTest.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/ControllerApisTest.scala
|
scanned
|
file
|
61.9 KB
|
ControllerApisTest.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/ControllerConfigurationValidatorTest.scala
|
scanned
|
file
|
10.0 KB
|
ControllerConfigurationValidatorTest.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/ControllerMutationQuotaManagerTest.scala
|
scanned
|
file
|
9.4 KB
|
ControllerMutationQuotaManagerTest.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/ControllerMutationQuotaTest.scala
|
scanned
|
file
|
19.2 KB
|
ControllerMutationQuotaTest.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/ControllerRegistrationManagerTest.scala
|
scanned
|
file
|
10.7 KB
|
ControllerRegistrationManagerTest.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/CreateTopicsRequestTest.scala
|
scanned
|
file
|
7.4 KB
|
CreateTopicsRequestTest.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/DefaultApiVersionManagerTest.scala
|
scanned
|
file
|
5.1 KB
|
DefaultApiVersionManagerTest.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/DelegationTokenRequestsOnPlainTextTest.scala
|
scanned
|
file
|
3.0 KB
|
DelegationTokenRequestsOnPlainTextTest.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/DelegationTokenRequestsTest.scala
|
scanned
|
file
|
8.8 KB
|
DelegationTokenRequestsTest.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/DelegationTokenRequestsWithDisableTokenFeatureTest.scala
|
scanned
|
file
|
3.6 KB
|
DelegationTokenRequestsWithDisableTokenFeatureTest.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/DeleteGroupsRequestTest.scala
|
scanned
|
file
|
4.2 KB
|
DeleteGroupsRequestTest.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/DeleteRecordsRequestTest.scala
|
scanned
|
file
|
7.6 KB
|
DeleteRecordsRequestTest.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/DeleteTopicsRequestTest.scala
|
scanned
|
file
|
6.1 KB
|
DeleteTopicsRequestTest.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/DeleteTopicsRequestWithDeletionDisabledTest.scala
|
scanned
|
file
|
2.9 KB
|
DeleteTopicsRequestWithDeletionDisabledTest.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|