|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/DescribeClusterRequestTest.scala
|
scanned
|
file
|
4.1 KB
|
DescribeClusterRequestTest.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/DescribeGroupsRequestTest.scala
|
scanned
|
file
|
4.7 KB
|
DescribeGroupsRequestTest.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/DescribeLogDirsRequestTest.scala
|
scanned
|
file
|
3.7 KB
|
DescribeLogDirsRequestTest.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/DescribeQuorumRequestTest.scala
|
scanned
|
file
|
3.9 KB
|
DescribeQuorumRequestTest.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/DescribeUserScramCredentialsRequestNotAuthorizedTest.scala
|
scanned
|
file
|
2.6 KB
|
DescribeUserScramCredentialsRequestNotAuthorizedTest.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/DescribeUserScramCredentialsRequestTest.scala
|
scanned
|
file
|
6.6 KB
|
DescribeUserScramCredentialsRequestTest.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/DynamicBrokerConfigTest.scala
|
scanned
|
file
|
57.6 KB
|
DynamicBrokerConfigTest.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/DynamicConfigChangeTest.scala
|
scanned
|
file
|
25.0 KB
|
DynamicConfigChangeTest.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/EdgeCaseRequestTest.scala
|
scanned
|
file
|
7.6 KB
|
EdgeCaseRequestTest.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/epoch
|
scanned
|
directory
|
|
epoch
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/epoch/LeaderEpochFileCacheTest.scala
|
scanned
|
file
|
19.9 KB
|
LeaderEpochFileCacheTest.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/epoch/LeaderEpochIntegrationTest.scala
|
scanned
|
file
|
13.4 KB
|
LeaderEpochIntegrationTest.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/epoch/OffsetsForLeaderEpochTest.scala
|
scanned
|
file
|
7.0 KB
|
OffsetsForLeaderEpochTest.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/epoch/util
|
scanned
|
directory
|
|
util
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/epoch/util/MockBlockingSender.scala
|
scanned
|
file
|
6.6 KB
|
MockBlockingSender.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/ExpiringErrorCacheTest.scala
|
scanned
|
file
|
12.9 KB
|
ExpiringErrorCacheTest.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/FetcherThreadTestUtils.scala
|
scanned
|
file
|
1.6 KB
|
FetcherThreadTestUtils.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/FetchRequestMaxBytesTest.scala
|
scanned
|
file
|
4.9 KB
|
FetchRequestMaxBytesTest.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/FetchRequestTest.scala
|
scanned
|
file
|
31.6 KB
|
FetchRequestTest.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/FetchSessionTest.scala
|
scanned
|
file
|
91.2 KB
|
FetchSessionTest.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/ForwardingManagerTest.scala
|
scanned
|
file
|
13.9 KB
|
ForwardingManagerTest.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/GroupCoordinatorBaseRequestTest.scala
|
scanned
|
file
|
39.1 KB
|
GroupCoordinatorBaseRequestTest.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/HeartbeatRequestTest.scala
|
scanned
|
file
|
6.2 KB
|
HeartbeatRequestTest.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/HighwatermarkPersistenceTest.scala
|
scanned
|
file
|
8.2 KB
|
HighwatermarkPersistenceTest.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/IsrExpirationTest.scala
|
scanned
|
file
|
10.4 KB
|
IsrExpirationTest.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/JoinGroupRequestTest.scala
|
scanned
|
file
|
14.2 KB
|
JoinGroupRequestTest.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/KafkaApisTest.scala
|
scanned
|
file
|
631.5 KB
|
KafkaApisTest.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/KafkaConfigTest.scala
|
scanned
|
file
|
108.9 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/server/KafkaMetricReporterExceptionHandlingTest.scala
|
scanned
|
file
|
4.1 KB
|
KafkaMetricReporterExceptionHandlingTest.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/KafkaMetricsReporterTest.scala
|
scanned
|
file
|
3.6 KB
|
KafkaMetricsReporterTest.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/KafkaRaftServerTest.scala
|
scanned
|
file
|
13.9 KB
|
KafkaRaftServerTest.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/LeaveGroupRequestTest.scala
|
scanned
|
file
|
7.9 KB
|
LeaveGroupRequestTest.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/ListGroupsRequestTest.scala
|
scanned
|
file
|
10.2 KB
|
ListGroupsRequestTest.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/ListOffsetsRequestTest.scala
|
scanned
|
file
|
14.0 KB
|
ListOffsetsRequestTest.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/ListOffsetsRequestWithRemoteStoreTest.scala
|
scanned
|
file
|
2.0 KB
|
ListOffsetsRequestWithRemoteStoreTest.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/LogDirFailureTest.scala
|
scanned
|
file
|
11.5 KB
|
LogDirFailureTest.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/LogOffsetTest.scala
|
scanned
|
file
|
10.6 KB
|
LogOffsetTest.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/LogRecoveryTest.scala
|
scanned
|
file
|
11.0 KB
|
LogRecoveryTest.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/metadata
|
scanned
|
directory
|
|
metadata
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataPublisherTest.scala
|
scanned
|
file
|
13.6 KB
|
BrokerMetadataPublisherTest.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/MetadataCacheTest.scala
|
scanned
|
file
|
41.5 KB
|
MetadataCacheTest.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/MetadataRequestTest.scala
|
scanned
|
file
|
14.8 KB
|
MetadataRequestTest.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/MockFetcherThread.scala
|
scanned
|
file
|
7.5 KB
|
MockFetcherThread.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/MockLeaderEndPoint.scala
|
scanned
|
file
|
12.0 KB
|
MockLeaderEndPoint.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/MockNodeToControllerChannelManager.scala
|
scanned
|
file
|
3.6 KB
|
MockNodeToControllerChannelManager.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/MockTierStateMachine.scala
|
scanned
|
file
|
2.1 KB
|
MockTierStateMachine.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/OffsetCommitRequestTest.scala
|
scanned
|
file
|
5.3 KB
|
OffsetCommitRequestTest.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/OffsetDeleteRequestTest.scala
|
scanned
|
file
|
5.1 KB
|
OffsetDeleteRequestTest.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/OffsetFetchRequestTest.scala
|
scanned
|
file
|
27.3 KB
|
OffsetFetchRequestTest.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/OffsetsForLeaderEpochRequestTest.scala
|
scanned
|
file
|
6.0 KB
|
OffsetsForLeaderEpochRequestTest.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/ProduceRequestTest.scala
|
scanned
|
file
|
14.4 KB
|
ProduceRequestTest.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/RegistrationTestContext.scala
|
scanned
|
file
|
3.4 KB
|
RegistrationTestContext.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/ReplicaAlterLogDirsThreadTest.scala
|
scanned
|
file
|
52.3 KB
|
ReplicaAlterLogDirsThreadTest.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/ReplicaFetcherThreadTest.scala
|
scanned
|
file
|
34.7 KB
|
ReplicaFetcherThreadTest.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/ReplicaFetchTest.scala
|
scanned
|
file
|
2.7 KB
|
ReplicaFetchTest.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/ReplicaManagerConcurrencyTest.scala
|
scanned
|
file
|
17.2 KB
|
ReplicaManagerConcurrencyTest.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/ReplicaManagerQuotasTest.scala
|
scanned
|
file
|
14.2 KB
|
ReplicaManagerQuotasTest.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/ReplicaManagerTest.scala
|
scanned
|
file
|
279.5 KB
|
ReplicaManagerTest.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/ReplicationQuotaManagerTest.scala
|
scanned
|
file
|
4.4 KB
|
ReplicationQuotaManagerTest.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/ReplicationQuotasTest.scala
|
scanned
|
file
|
13.3 KB
|
ReplicationQuotasTest.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/RequestQuotaTest.scala
|
scanned
|
file
|
40.8 KB
|
RequestQuotaTest.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/SaslApiVersionsRequestTest.scala
|
scanned
|
file
|
4.4 KB
|
SaslApiVersionsRequestTest.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/ServerMetricsTest.scala
|
scanned
|
file
|
1.8 KB
|
ServerMetricsTest.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/ServerShutdownTest.scala
|
scanned
|
file
|
8.8 KB
|
ServerShutdownTest.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/ServerTest.scala
|
scanned
|
file
|
1.9 KB
|
ServerTest.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/ShareFetchAcknowledgeRequestTest.scala
|
scanned
|
file
|
134.7 KB
|
ShareFetchAcknowledgeRequestTest.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/ShareGroupDescribeRequestTest.scala
|
scanned
|
file
|
5.5 KB
|
ShareGroupDescribeRequestTest.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/ShareGroupHeartbeatRequestTest.scala
|
scanned
|
file
|
46.4 KB
|
ShareGroupHeartbeatRequestTest.scala
|
.scala
|
Scala
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/server/StreamsGroupDescribeRequestTest.scala
|
scanned
|
file
|
14.2 KB
|
StreamsGroupDescribeRequestTest.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/StreamsGroupHeartbeatRequestTest.scala
|
scanned
|
file
|
48.2 KB
|
StreamsGroupHeartbeatRequestTest.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/SyncGroupRequestTest.scala
|
scanned
|
file
|
9.5 KB
|
SyncGroupRequestTest.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/ThrottledChannelExpirationTest.scala
|
scanned
|
file
|
3.2 KB
|
ThrottledChannelExpirationTest.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/TierStateMachineTest.scala
|
scanned
|
file
|
10.1 KB
|
TierStateMachineTest.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/TxnOffsetCommitRequestTest.scala
|
scanned
|
file
|
11.6 KB
|
TxnOffsetCommitRequestTest.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/WriteTxnMarkersRequestTest.scala
|
scanned
|
file
|
6.9 KB
|
WriteTxnMarkersRequestTest.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/tools
|
scanned
|
directory
|
|
tools
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/tools/DumpLogSegmentsTest.scala
|
scanned
|
file
|
50.1 KB
|
DumpLogSegmentsTest.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/tools/StorageToolTest.scala
|
scanned
|
file
|
38.3 KB
|
StorageToolTest.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/utils
|
scanned
|
directory
|
|
utils
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/unit/kafka/utils/CoreUtilsTest.scala
|
scanned
|
file
|
2.8 KB
|
CoreUtilsTest.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/utils/TestUtils.scala
|
scanned
|
file
|
65.3 KB
|
TestUtils.scala
|
.scala
|
Scala
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/doap_Kafka.rdf
|
scanned
|
file
|
3.0 KB
|
doap_Kafka.rdf
|
.rdf
|
|
text/xml
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker
|
scanned
|
directory
|
|
docker
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/common.py
|
scanned
|
file
|
2.0 KB
|
common.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_build_test.py
|
scanned
|
file
|
4.8 KB
|
docker_build_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_image_build_test.py
|
scanned
|
file
|
4.3 KB
|
docker_official_image_build_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images
|
scanned
|
directory
|
|
docker_official_images
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0
|
scanned
|
directory
|
|
3.7.0
|
.0
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm
|
scanned
|
directory
|
|
jvm
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/Dockerfile
|
scanned
|
file
|
3.8 KB
|
Dockerfile
|
|
verilog
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/jsa_launch
|
scanned
|
file
|
1.9 KB
|
jsa_launch
|
|
Bash
|
text/x-shellscript
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/launch
|
scanned
|
file
|
3.2 KB
|
launch
|
|
Bash
|
text/x-shellscript
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/resources
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/resources/common-scripts
|
scanned
|
directory
|
|
common-scripts
|
|
|
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/resources/common-scripts/bash-config
|
scanned
|
file
|
979 bytes
|
bash-config
|
|
verilog
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/resources/common-scripts/configure
|
application-package
|
file
|
4.4 KB
|
configure
|
|
Bash
|
text/x-shellscript
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/resources/common-scripts/configureDefaults
|
scanned
|
file
|
1.1 KB
|
configureDefaults
|
|
Bash
|
text/x-shellscript
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/3.7.0/jvm/resources/common-scripts/run
|
scanned
|
file
|
1.2 KB
|
run
|
|
Bash
|
text/x-shellscript
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_official_images/.gitkeep
|
ignored-empty-file
|
file
|
0 bytes
|
.gitkeep
|
|
|
inode/x-empty
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docker/docker_release.py
|
scanned
|
file
|
3.3 KB
|
docker_release.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|