6,866 results
« Page 27 of 69 »
Detected license expression: _ANY_
View the resource tree
Packages
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSinkIntegrationTest.java scanned file 6.9 KB MonitorableSinkIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceConnector.java scanned file 2.6 KB MonitorableSourceConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceIntegrationTest.java scanned file 6.0 KB MonitorableSourceIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java scanned file 54.7 KB OffsetsApiIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/RebalanceSourceConnectorsIntegrationTest.java scanned file 16.4 KB RebalanceSourceConnectorsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/RestExtensionIntegrationTest.java scanned file 8.6 KB RestExtensionIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/RestForwardingIntegrationTest.java scanned file 11.9 KB RestForwardingIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/RuntimeHandles.java scanned file 2.2 KB RuntimeHandles.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java scanned file 6.9 KB SessionedProtocolIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/SinkConnectorsIntegrationTest.java scanned file 14.7 KB SinkConnectorsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/SourceConnectorsIntegrationTest.java scanned file 11.7 KB SourceConnectorsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/StandaloneWorkerIntegrationTest.java scanned file 17.0 KB StandaloneWorkerIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartAndStopCounter.java scanned file 5.8 KB StartAndStopCounter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartAndStopCounterTest.java scanned file 3.7 KB StartAndStopCounterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartAndStopLatch.java scanned file 4.5 KB StartAndStopLatch.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartAndStopLatchTest.java scanned file 4.7 KB StartAndStopLatchTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/StartsAndStops.java scanned file 903 bytes StartsAndStops.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/TaskHandle.java scanned file 13.0 KB TaskHandle.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/TestableSinkConnector.java scanned file 6.4 KB TestableSinkConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/TestableSourceConnector.java scanned file 13.5 KB TestableSourceConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java scanned file 14.9 KB TransformationIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java scanned file 67.1 KB AbstractHerderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTaskTest.java scanned file 46.3 KB AbstractWorkerSourceTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectMetricsTest.java scanned file 16.7 KB ConnectMetricsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ConnectorConfigTest.java scanned file 21.8 KB ConnectorConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocolCompatibilityTest.java scanned file 11.5 KB ConnectProtocolCompatibilityTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedConfigTest.java scanned file 23.3 KB DistributedConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedHerderTest.java scanned file 201.0 KB DistributedHerderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignorTest.java scanned file 69.3 KB IncrementalCooperativeAssignorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/SampleConnectorClientConfigOverridePolicy.java scanned file 1.2 KB SampleConnectorClientConfigOverridePolicy.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncrementalTest.java scanned file 24.8 KB WorkerCoordinatorIncrementalTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorTest.java scanned file 30.9 KB WorkerCoordinatorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMemberTest.java scanned file 6.0 KB WorkerGroupMemberTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java scanned file 26.3 KB ErrorHandlingTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/ErrorReporterTest.java scanned file 17.4 KB ErrorReporterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java scanned file 21.9 KB RetryWithToleranceOperatorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporterTest.java scanned file 4.4 KB WorkerErrantRecordReporterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTaskTest.java scanned file 54.3 KB ExactlyOnceWorkerSourceTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/health/ConnectClusterStateImplTest.java scanned file 4.3 KB ConnectClusterStateImplTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/InternalSinkRecordTest.java scanned file 3.3 KB InternalSinkRecordTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoaderTest.java scanned file 14.5 KB DelegatingClassLoaderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/MultiVersionTest.java scanned file 17.1 KB MultiVersionTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginDescTest.java scanned file 12.4 KB PluginDescTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginRecommenderTest.java scanned file 9.4 KB PluginRecommenderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginScannerTest.java scanned file 6.4 KB PluginScannerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginsTest.java scanned file 33.9 KB PluginsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java scanned file 32.0 KB PluginUtilsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SamplingTestPlugin.java scanned file 4.3 KB SamplingTestPlugin.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SynchronizationTest.java scanned file 19.1 KB SynchronizationTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/TestPlugins.java scanned file 23.3 KB TestPlugins.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/VersionedPluginBuilder.java scanned file 3.9 KB VersionedPluginBuilder.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/LoggersTest.java scanned file 7.0 KB LoggersTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockConnectMetrics.java scanned file 8.7 KB MockConnectMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockLoggersTest.java scanned file 10.7 KB MockLoggersTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/RestartPlanTest.java scanned file 4.8 KB RestartPlanTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/RestartRequestTest.java scanned file 5.6 KB RestartRequestTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/ConnectRestServerTest.java scanned file 20.4 KB ConnectRestServerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorOffsetsTest.java scanned file 2.2 KB ConnectorOffsetsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorTypeTest.java scanned file 1.6 KB ConnectorTypeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequestTest.java scanned file 2.8 KB CreateConnectorRequestTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/PluginInfoTest.java scanned file 3.2 KB PluginInfoTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignatureTest.java scanned file 6.9 KB InternalRequestSignatureTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResourceTest.java scanned file 27.1 KB ConnectorPluginsResourceTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResourceTest.java scanned file 52.6 KB ConnectorsResourceTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/InternalConnectResourceTest.java scanned file 9.5 KB InternalConnectResourceTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResourceTest.java scanned file 5.8 KB LoggingResourceTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/RootResourceTest.java scanned file 6.9 KB RootResourceTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestClientTest.java scanned file 13.4 KB RestClientTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestServerConfigTest.java scanned file 7.0 KB RestServerConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/util/SSLUtilsTest.java scanned file 9.8 KB SSLUtilsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleConverterWithHeaders.java scanned file 3.1 KB SampleConverterWithHeaders.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleHeaderConverter.java scanned file 1.9 KB SampleHeaderConverter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SamplePredicate.java scanned file 1.9 KB SamplePredicate.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleSinkConnector.java scanned file 2.1 KB SampleSinkConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleSourceConnector.java scanned file 2.7 KB SampleSourceConnector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SampleTransformation.java scanned file 1.9 KB SampleTransformation.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceConnectorConfigTest.java scanned file 8.4 KB SourceConnectorConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitterTest.java scanned file 6.5 KB SourceTaskOffsetCommitterTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfigTest.java scanned file 3.8 KB StandaloneConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java scanned file 62.8 KB StandaloneHerderTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/StateTrackerTest.java scanned file 5.1 KB StateTrackerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/SubmittedRecordsTest.java scanned file 16.9 KB SubmittedRecordsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TransformationConfigTest.java scanned file 10.1 KB TransformationConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/TransformationStageTest.java scanned file 3.3 KB TransformationStageTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTest.java scanned file 4.5 KB WorkerConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConfigTransformerTest.java scanned file 6.2 KB WorkerConfigTransformerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerConnectorTest.java scanned file 28.4 KB WorkerConnectorTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerMetricsGroupTest.java scanned file 8.3 KB WorkerMetricsGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskTest.java scanned file 92.0 KB WorkerSinkTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSinkTaskThreadedTest.java scanned file 30.0 KB WorkerSinkTaskThreadedTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java scanned file 42.5 KB WorkerSourceTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java scanned file 13.3 KB WorkerTaskTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java scanned file 171.3 KB WorkerTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTestUtils.java scanned file 10.1 KB WorkerTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTransactionContextTest.java scanned file 3.9 KB WorkerTransactionContextTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStoreTest.java scanned file 22.0 KB ConnectorOffsetBackingStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java scanned file 9.0 KB FileOffsetBackingStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java scanned file 96.2 KB KafkaConfigBackingStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java scanned file 28.1 KB KafkaOffsetBackingStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreFormatTest.java scanned file 13.1 KB KafkaStatusBackingStoreFormatTest.java .java Java text/x-java apache-2.0