|
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/util
|
scanned
|
directory
|
|
util
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone
|
scanned
|
directory
|
|
standalone
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/storage
|
scanned
|
directory
|
|
storage
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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-1778570057504.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
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaStatusBackingStoreTest.java
|
scanned
|
file
|
19.9 KB
|
KafkaStatusBackingStoreTest.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/storage/MemoryConfigBackingStoreTest.java
|
scanned
|
file
|
9.8 KB
|
MemoryConfigBackingStoreTest.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/storage/MemoryStatusBackingStoreTest.java
|
scanned
|
file
|
2.8 KB
|
MemoryStatusBackingStoreTest.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/storage/OffsetStorageWriterTest.java
|
scanned
|
file
|
10.7 KB
|
OffsetStorageWriterTest.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/storage/OffsetUtilsTest.java
|
scanned
|
file
|
6.6 KB
|
OffsetUtilsTest.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/test
|
scanned
|
directory
|
|
test
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/test/util
|
scanned
|
directory
|
|
util
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/test/util/ConcurrencyUtils.java
|
scanned
|
file
|
2.3 KB
|
ConcurrencyUtils.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/test/util/MockitoUtils.java
|
scanned
|
file
|
2.7 KB
|
MockitoUtils.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/util
|
scanned
|
directory
|
|
util
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters
|
scanned
|
directory
|
|
clusters
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/ConnectAssertions.java
|
scanned
|
file
|
26.8 KB
|
ConnectAssertions.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/util/clusters/EmbeddedConnectBuilder.java
|
scanned
|
file
|
3.1 KB
|
EmbeddedConnectBuilder.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/util/clusters/EmbeddedConnectCluster.java
|
scanned
|
file
|
9.1 KB
|
EmbeddedConnectCluster.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/util/clusters/EmbeddedConnect.java
|
scanned
|
file
|
45.1 KB
|
EmbeddedConnect.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/util/clusters/EmbeddedConnectStandalone.java
|
scanned
|
file
|
7.2 KB
|
EmbeddedConnectStandalone.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/util/clusters/EmbeddedKafkaCluster.java
|
scanned
|
file
|
33.7 KB
|
EmbeddedKafkaCluster.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/util/clusters/UngracefulShutdownException.java
|
scanned
|
file
|
1.4 KB
|
UngracefulShutdownException.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/util/clusters/WorkerHandle.java
|
scanned
|
file
|
3.9 KB
|
WorkerHandle.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/util/ConnectUtilsTest.java
|
scanned
|
file
|
8.7 KB
|
ConnectUtilsTest.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/util/ConvertingFutureCallbackTest.java
|
scanned
|
file
|
9.3 KB
|
ConvertingFutureCallbackTest.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/util/KafkaBasedLogTest.java
|
scanned
|
file
|
25.6 KB
|
KafkaBasedLogTest.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/util/LoggingContextTest.java
|
scanned
|
file
|
7.6 KB
|
LoggingContextTest.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/util/RetryUtilTest.java
|
scanned
|
file
|
8.4 KB
|
RetryUtilTest.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/util/SharedTopicAdminTest.java
|
scanned
|
file
|
4.4 KB
|
SharedTopicAdminTest.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/util/SinkUtilsTest.java
|
scanned
|
file
|
9.5 KB
|
SinkUtilsTest.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/util/TableTest.java
|
scanned
|
file
|
1.7 KB
|
TableTest.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/util/TestFuture.java
|
scanned
|
file
|
2.9 KB
|
TestFuture.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/util/TopicAdminTest.java
|
scanned
|
file
|
49.7 KB
|
TopicAdminTest.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/util/TopicCreationTest.java
|
scanned
|
file
|
36.2 KB
|
TopicCreationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/log4j2.yaml
|
scanned
|
file
|
1.4 KB
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/META-INF
|
scanned
|
directory
|
|
META-INF
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/META-INF/services
|
scanned
|
directory
|
|
services
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension
|
scanned
|
file
|
872 bytes
|
org.apache.kafka.connect.rest.ConnectRestExtension
|
.ConnectRestExtension
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector
|
scanned
|
file
|
1.3 KB
|
org.apache.kafka.connect.sink.SinkConnector
|
.SinkConnector
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector
|
scanned
|
file
|
1.6 KB
|
org.apache.kafka.connect.source.SourceConnector
|
.SourceConnector
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.storage.Converter
|
scanned
|
file
|
1.3 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/test/resources/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter
|
scanned
|
file
|
1.3 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/resources/META-INF/services/org.apache.kafka.connect.transforms.predicates.Predicate
|
scanned
|
file
|
908 bytes
|
org.apache.kafka.connect.transforms.predicates.Predicate
|
.Predicate
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.transforms.Transformation
|
scanned
|
file
|
1.4 KB
|
org.apache.kafka.connect.transforms.Transformation
|
.Transformation
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins
|
scanned
|
directory
|
|
test-plugins
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/aliased-static-field
|
scanned
|
directory
|
|
aliased-static-field
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/aliased-static-field/META-INF
|
scanned
|
directory
|
|
META-INF
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/aliased-static-field/META-INF/services
|
scanned
|
directory
|
|
services
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/aliased-static-field/META-INF/services/org.apache.kafka.connect.storage.Converter
|
scanned
|
file
|
825 bytes
|
org.apache.kafka.connect.storage.Converter
|
.Converter
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/aliased-static-field/test
|
scanned
|
directory
|
|
test
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/aliased-static-field/test/plugins
|
scanned
|
directory
|
|
plugins
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/aliased-static-field/test/plugins/AliasedStaticField.java
|
scanned
|
file
|
2.4 KB
|
AliasedStaticField.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/always-throw-exception
|
scanned
|
directory
|
|
always-throw-exception
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/always-throw-exception/META-INF
|
scanned
|
directory
|
|
META-INF
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/always-throw-exception/META-INF/services
|
scanned
|
directory
|
|
services
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/always-throw-exception/META-INF/services/org.apache.kafka.connect.storage.Converter
|
scanned
|
file
|
827 bytes
|
org.apache.kafka.connect.storage.Converter
|
.Converter
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/always-throw-exception/test
|
scanned
|
directory
|
|
test
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/always-throw-exception/test/plugins
|
scanned
|
directory
|
|
plugins
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/always-throw-exception/test/plugins/AlwaysThrowException.java
|
scanned
|
file
|
1.7 KB
|
AlwaysThrowException.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/bad-packaging
|
scanned
|
directory
|
|
bad-packaging
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF
|
scanned
|
directory
|
|
META-INF
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services
|
scanned
|
directory
|
|
services
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy
|
scanned
|
file
|
841 bytes
|
org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy
|
.ConnectorClientConfigOverridePolicy
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension
|
scanned
|
file
|
842 bytes
|
org.apache.kafka.connect.rest.ConnectRestExtension
|
.ConnectRestExtension
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.sink.SinkConnector
|
scanned
|
file
|
1.1 KB
|
org.apache.kafka.connect.sink.SinkConnector
|
.SinkConnector
|
|
text/plain
|
|
apache-2.0
|
|
|