336 results
« Page 3 of 4 »
Programming language: Scala
View the resource tree
Packages
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
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/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/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/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/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/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/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala scanned file 7.5 KB StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinScalaIntegrationTestBase.scala scanned file 5.1 KB StreamToTableJoinScalaIntegrationTestBase.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/utils/StreamToTableJoinTestData.scala scanned file 2.2 KB StreamToTableJoinTestData.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/scala/org/apache/kafka/streams/integration/WordCountTest.scala scanned file 9.1 KB WordCountTest.scala .scala Scala text/plain apache-2.0