5,643 results
« Page 23 of 57 »
Status: scanned
Programming language: Java
View the resource tree
Packages
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java scanned file 8.1 KB MemoryConfigBackingStore.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/main/java/org/apache/kafka/connect/storage/MemoryOffsetBackingStore.java scanned file 3.0 KB MemoryOffsetBackingStore.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/main/java/org/apache/kafka/connect/storage/MemoryStatusBackingStore.java scanned file 4.4 KB MemoryStatusBackingStore.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/main/java/org/apache/kafka/connect/storage/OffsetBackingStore.java scanned file 2.9 KB OffsetBackingStore.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/main/java/org/apache/kafka/connect/storage/OffsetStorageReaderImpl.java scanned file 7.3 KB OffsetStorageReaderImpl.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/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java scanned file 11.3 KB OffsetStorageWriter.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/main/java/org/apache/kafka/connect/storage/OffsetUtils.java scanned file 6.2 KB OffsetUtils.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/main/java/org/apache/kafka/connect/storage/PrivilegedWriteException.java scanned file 1.2 KB PrivilegedWriteException.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/main/java/org/apache/kafka/connect/storage/StatusBackingStore.java scanned file 4.4 KB StatusBackingStore.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/main/java/org/apache/kafka/connect/tools/PredicateDoc.java scanned file 3.0 KB PredicateDoc.java .java Java text/html apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/tools/TransformationDoc.java scanned file 4.3 KB TransformationDoc.java .java Java text/html apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/util/Callback.java scanned file 1.6 KB Callback.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/main/java/org/apache/kafka/connect/util/ConcreteSubClassValidator.java scanned file 1.8 KB ConcreteSubClassValidator.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/main/java/org/apache/kafka/connect/util/ConnectorTaskId.java scanned file 1.9 KB ConnectorTaskId.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/main/java/org/apache/kafka/connect/util/ConnectUtils.java scanned file 10.5 KB ConnectUtils.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/main/java/org/apache/kafka/connect/util/ConvertingFutureCallback.java scanned file 4.4 KB ConvertingFutureCallback.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/main/java/org/apache/kafka/connect/util/FutureCallback.java scanned file 1.3 KB FutureCallback.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/main/java/org/apache/kafka/connect/util/InstantiableClassValidator.java scanned file 2.1 KB InstantiableClassValidator.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/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java scanned file 29.4 KB KafkaBasedLog.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/main/java/org/apache/kafka/connect/util/LoggingContext.java scanned file 8.3 KB LoggingContext.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/main/java/org/apache/kafka/connect/util/RetryUtil.java scanned file 5.2 KB RetryUtil.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/main/java/org/apache/kafka/connect/util/SafeObjectInputStream.java scanned file 2.4 KB SafeObjectInputStream.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/main/java/org/apache/kafka/connect/util/SharedTopicAdmin.java scanned file 5.6 KB SharedTopicAdmin.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/main/java/org/apache/kafka/connect/util/SinkUtils.java scanned file 6.7 KB SinkUtils.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/main/java/org/apache/kafka/connect/util/StagedTimeoutException.java scanned file 1.2 KB StagedTimeoutException.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/main/java/org/apache/kafka/connect/util/Stage.java scanned file 2.6 KB Stage.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/main/java/org/apache/kafka/connect/util/Table.java scanned file 1.9 KB Table.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/main/java/org/apache/kafka/connect/util/TemporaryStage.java scanned file 1.3 KB TemporaryStage.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/main/java/org/apache/kafka/connect/util/TopicAdmin.java scanned file 37.9 KB TopicAdmin.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/main/java/org/apache/kafka/connect/util/TopicCreationGroup.java scanned file 6.1 KB TopicCreationGroup.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/main/java/org/apache/kafka/connect/util/TopicCreation.java scanned file 5.5 KB TopicCreation.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/cli/AbstractConnectCliTest.java scanned file 7.9 KB AbstractConnectCliTest.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/cli/ConnectStandaloneTest.java scanned file 5.4 KB ConnectStandaloneTest.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/connector/policy/AllowlistConnectorClientConfigOverridePolicyTest.java scanned file 2.7 KB AllowlistConnectorClientConfigOverridePolicyTest.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/connector/policy/BaseConnectorClientConfigOverridePolicyTest.java scanned file 2.4 KB BaseConnectorClientConfigOverridePolicyTest.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/connector/policy/NoneConnectorClientConfigOverridePolicyTest.java scanned file 1.8 KB NoneConnectorClientConfigOverridePolicyTest.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/connector/policy/PrincipalConnectorClientConfigOverridePolicyTest.java scanned file 1.9 KB PrincipalConnectorClientConfigOverridePolicyTest.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/converters/BooleanConverterTest.java scanned file 4.0 KB BooleanConverterTest.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/converters/ByteArrayConverterTest.java scanned file 4.1 KB ByteArrayConverterTest.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/converters/DoubleConverterTest.java scanned file 1.5 KB DoubleConverterTest.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/converters/FloatConverterTest.java scanned file 1.5 KB FloatConverterTest.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/converters/IntegerConverterTest.java scanned file 1.5 KB IntegerConverterTest.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/converters/LongConverterTest.java scanned file 1.5 KB LongConverterTest.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/converters/NumberConverterTest.java scanned file 4.1 KB NumberConverterTest.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/converters/ShortConverterTest.java scanned file 1.5 KB ShortConverterTest.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/BlockingConnectorTest.java scanned file 33.0 KB BlockingConnectorTest.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/ConnectorClientPolicyIntegrationTest.java scanned file 8.5 KB ConnectorClientPolicyIntegrationTest.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/ConnectorHandle.java scanned file 15.0 KB ConnectorHandle.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/ConnectorRestartApiIntegrationTest.java scanned file 21.1 KB ConnectorRestartApiIntegrationTest.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/ConnectorTopicsIntegrationTest.java scanned file 15.4 KB ConnectorTopicsIntegrationTest.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/ConnectorValidationIntegrationTest.java scanned file 25.9 KB ConnectorValidationIntegrationTest.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/ConnectWorkerIntegrationTest.java scanned file 67.3 KB ConnectWorkerIntegrationTest.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/ErrantRecordSinkConnector.java scanned file 3.0 KB ErrantRecordSinkConnector.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/ErrorHandlingIntegrationTest.java scanned file 15.3 KB ErrorHandlingIntegrationTest.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/ExactlyOnceSourceIntegrationTest.java scanned file 67.9 KB ExactlyOnceSourceIntegrationTest.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/ExampleConnectIntegrationTest.java scanned file 11.3 KB ExampleConnectIntegrationTest.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/InternalTopicsIntegrationTest.java scanned file 16.1 KB InternalTopicsIntegrationTest.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/MonitorableSinkConnector.java scanned file 2.5 KB MonitorableSinkConnector.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/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