336 results
« Page 1 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/main/scala/kafka/admin/ConfigCommand.scala scanned file 42.3 KB ConfigCommand.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/main/scala/kafka/cluster/Partition.scala scanned file 85.5 KB Partition.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala scanned file 6.2 KB CoordinatorPartitionWriter.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala scanned file 57.7 KB TransactionCoordinator.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/coordinator/transaction/TransactionLog.scala scanned file 6.1 KB TransactionLog.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala scanned file 22.7 KB TransactionMarkerChannelManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala scanned file 10.7 KB TransactionMarkerRequestCompletionHandler.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala scanned file 43.5 KB TransactionStateManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/docker/KafkaDockerWrapper.scala scanned file 13.5 KB KafkaDockerWrapper.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/main/scala/kafka/Kafka.scala scanned file 4.2 KB Kafka.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/log/LogManager.scala scanned file 68.0 KB LogManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala scanned file 2.8 KB KafkaCSVMetricsReporter.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/metrics/KafkaMetricsConfig.scala scanned file 1.7 KB KafkaMetricsConfig.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/metrics/KafkaMetricsReporter.scala scanned file 2.9 KB KafkaMetricsReporter.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/network/RequestChannel.scala scanned file 21.4 KB RequestChannel.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/network/SocketServer.scala scanned file 74.9 KB SocketServer.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/raft/DefaultExternalKRaftMetrics.scala scanned file 1.4 KB DefaultExternalKRaftMetrics.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/raft/KafkaMetadataLog.scala scanned file 27.2 KB KafkaMetadataLog.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/raft/KafkaRaftManager.scala scanned file 9.1 KB KafkaRaftManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/AbstractFetcherManager.scala scanned file 10.9 KB AbstractFetcherManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/AbstractFetcherThread.scala scanned file 47.0 KB AbstractFetcherThread.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/AclApis.scala scanned file 7.7 KB AclApis.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/AlterPartitionManager.scala scanned file 12.6 KB AlterPartitionManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/AuthHelper.scala scanned file 8.2 KB AuthHelper.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/AutoTopicCreationManager.scala scanned file 22.0 KB AutoTopicCreationManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/BrokerBlockingSender.scala scanned file 4.5 KB BrokerBlockingSender.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/BrokerLifecycleManager.scala scanned file 24.5 KB BrokerLifecycleManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/BrokerServer.scala scanned file 37.6 KB BrokerServer.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ConfigAdminManager.scala scanned file 20.5 KB ConfigAdminManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ConfigHandler.scala scanned file 9.1 KB ConfigHandler.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ConfigHelper.scala scanned file 17.9 KB ConfigHelper.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ControllerApis.scala scanned file 54.6 KB ControllerApis.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ControllerConfigurationValidator.scala scanned file 5.6 KB ControllerConfigurationValidator.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ControllerRegistrationManager.scala scanned file 11.0 KB ControllerRegistrationManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ControllerServer.scala scanned file 22.1 KB ControllerServer.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/DelayedFetch.scala scanned file 9.1 KB DelayedFetch.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/DelayedProduce.scala scanned file 6.0 KB DelayedProduce.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/DynamicBrokerConfig.scala scanned file 54.7 KB DynamicBrokerConfig.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/DynamicConfig.scala scanned file 2.9 KB DynamicConfig.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/EnvelopeUtils.scala scanned file 5.1 KB EnvelopeUtils.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/FetchSession.scala scanned file 38.2 KB FetchSession.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ForwardingManager.scala scanned file 8.9 KB ForwardingManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/KafkaApis.scala scanned file 209.7 KB KafkaApis.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/KafkaBroker.scala scanned file 5.4 KB KafkaBroker.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/KafkaConfig.scala scanned file 41.0 KB KafkaConfig.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/main/scala/kafka/server/KafkaRaftServer.scala scanned file 8.0 KB KafkaRaftServer.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/KafkaRequestHandler.scala scanned file 12.0 KB KafkaRequestHandler.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/LocalLeaderEndPoint.scala scanned file 11.1 KB LocalLeaderEndPoint.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala scanned file 16.8 KB BrokerMetadataPublisher.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/metadata/ClientQuotaMetadataManager.scala scanned file 8.4 KB ClientQuotaMetadataManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/metadata/DynamicConfigPublisher.scala scanned file 6.8 KB DynamicConfigPublisher.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/metadata/DynamicTopicClusterQuotaPublisher.scala scanned file 2.6 KB DynamicTopicClusterQuotaPublisher.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/metadata/KRaftMetadataCachePublisher.scala scanned file 1.3 KB KRaftMetadataCachePublisher.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala scanned file 21.6 KB KRaftMetadataCache.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/NodeToControllerChannelManager.scala scanned file 11.9 KB NodeToControllerChannelManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/RemoteLeaderEndPoint.scala scanned file 11.0 KB RemoteLeaderEndPoint.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ReplicaAlterLogDirsManager.scala scanned file 3.1 KB ReplicaAlterLogDirsManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala scanned file 11.7 KB ReplicaAlterLogDirsThread.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ReplicaFetcherManager.scala scanned file 2.8 KB ReplicaFetcherManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala scanned file 7.8 KB ReplicaFetcherThread.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/ReplicaManager.scala scanned file 129.3 KB ReplicaManager.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/RequestHandlerHelper.scala scanned file 6.6 KB RequestHandlerHelper.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/Server.scala scanned file 2.7 KB Server.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/SharedServer.scala scanned file 15.7 KB SharedServer.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/tools/DumpLogSegments.scala scanned file 32.1 KB DumpLogSegments.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/main/scala/kafka/tools/StorageTool.scala scanned file 20.4 KB StorageTool.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/main/scala/kafka/tools/TerseFailure.scala scanned file 1.3 KB TerseFailure.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/tools/TestRaftRequestHandler.scala scanned file 4.7 KB TestRaftRequestHandler.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/tools/TestRaftServer.scala scanned file 17.1 KB TestRaftServer.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/utils/Annotations.scala scanned file 1.3 KB Annotations.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/utils/CoreUtils.scala scanned file 8.1 KB CoreUtils.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/utils/Implicits.scala scanned file 1.6 KB Implicits.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/utils/Logging.scala scanned file 3.0 KB Logging.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/utils/Mx4jLoader.scala scanned file 3.1 KB Mx4jLoader.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/utils/VerifiableProperties.scala scanned file 7.0 KB VerifiableProperties.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/admin/RemoteTopicCrudTest.scala scanned file 4.1 KB RemoteTopicCrudTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/AbstractAuthorizerIntegrationTest.scala scanned file 6.3 KB AbstractAuthorizerIntegrationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/AbstractConsumerTest.scala scanned file 25.9 KB AbstractConsumerTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/AbstractSaslTest.scala scanned file 1.1 KB AbstractSaslTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala scanned file 202.3 KB AuthorizerIntegrationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/BaseAdminIntegrationTest.scala scanned file 11.8 KB BaseAdminIntegrationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/BaseConsumerTest.scala scanned file 6.9 KB BaseConsumerTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala scanned file 24.0 KB BaseProducerSendTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala scanned file 20.2 KB BaseQuotaTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/ClientIdQuotaTest.scala scanned file 2.7 KB ClientIdQuotaTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/ClientOAuthIntegrationTest.scala scanned file 14.1 KB ClientOAuthIntegrationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/ConsumerBounceTest.scala scanned file 6.8 KB ConsumerBounceTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/CustomQuotaCallbackTest.scala scanned file 22.5 KB CustomQuotaCallbackTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationTest.scala scanned file 7.8 KB DelegationTokenEndToEndAuthorizationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/DelegationTokenEndToEndAuthorizationWithOwnerTest.scala scanned file 6.7 KB DelegationTokenEndToEndAuthorizationWithOwnerTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala scanned file 28.3 KB EndToEndAuthorizationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/FixedPortTestUtils.scala scanned file 2.0 KB FixedPortTestUtils.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/GroupCoordinatorIntegrationTest.scala scanned file 14.8 KB GroupCoordinatorIntegrationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/GroupEndToEndAuthorizationTest.scala scanned file 2.2 KB GroupEndToEndAuthorizationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala scanned file 14.7 KB IntegrationTestHarness.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/MetricsTest.scala scanned file 16.1 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/integration/kafka/api/PlaintextAdminIntegrationTest.scala scanned file 237.4 KB PlaintextAdminIntegrationTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/PlaintextConsumerAssignorsTest.scala scanned file 17.3 KB PlaintextConsumerAssignorsTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala scanned file 3.1 KB PlaintextConsumerTest.scala .scala Scala text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/scala/integration/kafka/api/PlaintextEndToEndAuthorizationTest.scala scanned file 4.4 KB PlaintextEndToEndAuthorizationTest.scala .scala Scala text/plain apache-2.0