6,866 results
« Page 26 of 69 »
Detected license expression: _ANY_
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java scanned file 11.4 KB SinkConnectorConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java scanned file 18.2 KB SourceConnectorConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java scanned file 5.2 KB SourceTaskOffsetCommitter.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/HealthCheckThread.java scanned file 4.8 KB HealthCheckThread.java .java Java text/html apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneConfig.java scanned file 1.8 KB StandaloneConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java scanned file 25.8 KB StandaloneHerder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/StateTracker.java scanned file 7.5 KB StateTracker.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SubmittedRecords.java scanned file 14.3 KB SubmittedRecords.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TargetState.java scanned file 2.0 KB TargetState.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskConfig.java scanned file 1.8 KB TaskConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskPluginsMetadata.java scanned file 5.0 KB TaskPluginsMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskStatus.java scanned file 2.7 KB TaskStatus.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TooManyTasksException.java scanned file 1.9 KB TooManyTasksException.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicCreationConfig.java scanned file 8.5 KB TopicCreationConfig.java .java Java text/html apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TopicStatus.java scanned file 3.2 KB TopicStatus.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java scanned file 3.9 KB TransformationChain.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationStage.java scanned file 5.6 KB TransformationStage.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java scanned file 25.8 KB WorkerConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfigTransformer.java scanned file 4.3 KB WorkerConfigTransformer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java scanned file 23.1 KB WorkerConnector.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerInfo.java scanned file 3.3 KB WorkerInfo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java scanned file 130.8 KB Worker.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerMetricsGroup.java scanned file 8.2 KB WorkerMetricsGroup.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTaskContext.java scanned file 6.2 KB WorkerSinkTaskContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java scanned file 42.1 KB WorkerSinkTask.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTaskContext.java scanned file 2.4 KB WorkerSourceTaskContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java scanned file 15.3 KB WorkerSourceTask.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java scanned file 23.6 KB WorkerTask.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTransactionContext.java scanned file 4.4 KB WorkerTransactionContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/AppliedConnectorConfig.java scanned file 2.7 KB AppliedConnectorConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/CloseableOffsetStorageReader.java scanned file 1.4 KB CloseableOffsetStorageReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/ClusterConfigState.java scanned file 13.2 KB ClusterConfigState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConfigBackingStore.java scanned file 7.2 KB ConfigBackingStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java scanned file 21.6 KB ConnectorOffsetBackingStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/FileOffsetBackingStore.java scanned file 4.7 KB FileOffsetBackingStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java scanned file 70.1 KB KafkaConfigBackingStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java scanned file 18.6 KB KafkaOffsetBackingStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java scanned file 29.4 KB KafkaStatusBackingStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaTopicBasedBackingStore.java scanned file 3.8 KB KafkaTopicBasedBackingStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/resources/META-INF/services/org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy scanned file 1.1 KB 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/main/resources/META-INF/services/org.apache.kafka.connect.storage.Converter scanned file 1.1 KB 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/main/resources/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter scanned file 1.1 KB 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/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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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