8,627 results
« Page 30 of 87 »
View the resource tree
Packages
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 scanned directory resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/resources/META-INF scanned directory META-INF
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/resources/META-INF/services scanned directory services
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 scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect scanned directory connect
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/cli scanned directory cli
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 scanned directory connector
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/connector/policy scanned directory policy
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 scanned directory converters
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 scanned directory integration
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
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime scanned directory runtime
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed scanned directory distributed
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors scanned directory errors