1,443 results
« Page 7 of 15 »
Mime type: text/plain
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/service-loader/META-INF/services/org.apache.kafka.connect.storage.Converter scanned file 826 bytes org.apache.kafka.connect.storage.Converter .Converter text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/service-loader/META-INF/services/test.plugins.ServiceLoadedClass scanned file 827 bytes test.plugins.ServiceLoadedClass .ServiceLoadedClass text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/service-loader/test/plugins/ServiceLoadedSubclass.java scanned file 1.3 KB ServiceLoadedSubclass.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/subclass-of-classpath/META-INF/services/org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy scanned file 840 bytes org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy .ConnectorClientConfigOverridePolicy text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/subclass-of-classpath/META-INF/services/org.apache.kafka.connect.storage.Converter scanned file 835 bytes org.apache.kafka.connect.storage.Converter .Converter text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-converter/META-INF/services/org.apache.kafka.connect.storage.Converter scanned file 825 bytes org.apache.kafka.connect.storage.Converter .Converter text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-header-converter/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter scanned file 831 bytes org.apache.kafka.connect.storage.HeaderConverter .HeaderConverter text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-predicate/META-INF/services/org.apache.kafka.connect.transforms.predicates.Predicate scanned file 825 bytes org.apache.kafka.connect.transforms.predicates.Predicate .Predicate text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-sink-connector/META-INF/services/org.apache.kafka.connect.sink.SinkConnector scanned file 829 bytes org.apache.kafka.connect.sink.SinkConnector .SinkConnector text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-source-connector/META-INF/services/org.apache.kafka.connect.source.SourceConnector scanned file 831 bytes org.apache.kafka.connect.source.SourceConnector .SourceConnector text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/versioned-transformation/META-INF/services/org.apache.kafka.connect.transforms.Transformation scanned file 830 bytes org.apache.kafka.connect.transforms.Transformation .Transformation text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/package-info.java scanned file 917 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector scanned file 897 bytes org.apache.kafka.connect.sink.SinkConnector .SinkConnector text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector scanned file 953 bytes org.apache.kafka.connect.source.SourceConnector .SourceConnector text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.predicates.Predicate scanned file 981 bytes org.apache.kafka.connect.transforms.predicates.Predicate .Predicate text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation scanned file 2.1 KB org.apache.kafka.connect.transforms.Transformation .Transformation text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/CONTRIBUTING.md scanned file 720 bytes CONTRIBUTING.md .md text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorShardBuilderSupplier.java scanned file 1.2 KB CoordinatorShardBuilderSupplier.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/Serializer.java scanned file 1.1 KB Serializer.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/test/java/org/apache/kafka/coordinator/common/runtime/MockCoordinatorShardBuilderSupplier.java scanned file 1.2 KB MockCoordinatorShardBuilderSupplier.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/.gitignore scanned file 31 bytes .gitignore GAS text/plain
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/log/package.html scanned file 1.2 KB package.html .html HTML text/plain apache-2.0
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/network/package.html scanned file 1.7 KB package.html .html HTML text/plain apache-2.0
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/package.html scanned file 830 bytes package.html .html HTML text/plain apache-2.0
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/resources/log4j2.yaml scanned file 1.1 KB log4j2.yaml .yaml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/resources/minikdc-krb5.conf scanned file 977 bytes minikdc-krb5.conf .conf text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/core/src/test/resources/minikdc.ldiff scanned file 1.4 KB minikdc.ldiff .ldiff text/plain apache-2.0
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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