|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginDescTest.java
|
scanned
|
file
|
12.4 KB
|
PluginDescTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginRecommenderTest.java
|
scanned
|
file
|
9.4 KB
|
PluginRecommenderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginScannerTest.java
|
scanned
|
file
|
6.4 KB
|
PluginScannerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginsTest.java
|
scanned
|
file
|
33.9 KB
|
PluginsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java
|
scanned
|
file
|
32.0 KB
|
PluginUtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SamplingTestPlugin.java
|
scanned
|
file
|
4.3 KB
|
SamplingTestPlugin.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SynchronizationTest.java
|
scanned
|
file
|
19.1 KB
|
SynchronizationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/TestPlugins.java
|
scanned
|
file
|
23.3 KB
|
TestPlugins.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/VersionedPluginBuilder.java
|
scanned
|
file
|
3.9 KB
|
VersionedPluginBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/LoggersTest.java
|
scanned
|
file
|
7.0 KB
|
LoggersTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockConnectMetrics.java
|
scanned
|
file
|
8.7 KB
|
MockConnectMetrics.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/MockLoggersTest.java
|
scanned
|
file
|
10.7 KB
|
MockLoggersTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/RestartPlanTest.java
|
scanned
|
file
|
4.8 KB
|
RestartPlanTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/RestartRequestTest.java
|
scanned
|
file
|
5.6 KB
|
RestartRequestTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/ConnectRestServerTest.java
|
scanned
|
file
|
20.4 KB
|
ConnectRestServerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorOffsetsTest.java
|
scanned
|
file
|
2.2 KB
|
ConnectorOffsetsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorTypeTest.java
|
scanned
|
file
|
1.6 KB
|
ConnectorTypeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/CreateConnectorRequestTest.java
|
scanned
|
file
|
2.8 KB
|
CreateConnectorRequestTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/entities/PluginInfoTest.java
|
scanned
|
file
|
3.2 KB
|
PluginInfoTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/InternalRequestSignatureTest.java
|
scanned
|
file
|
6.9 KB
|
InternalRequestSignatureTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResourceTest.java
|
scanned
|
file
|
27.1 KB
|
ConnectorPluginsResourceTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResourceTest.java
|
scanned
|
file
|
52.6 KB
|
ConnectorsResourceTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/resources/InternalConnectResourceTest.java
|
scanned
|
file
|
9.5 KB
|
InternalConnectResourceTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-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/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/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/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/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/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/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/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/test/plugins/CoLocatedPlugin.java
|
scanned
|
file
|
1.6 KB
|
CoLocatedPlugin.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/test/plugins/DefaultConstructorPrivateConnector.java
|
scanned
|
file
|
1.8 KB
|
DefaultConstructorPrivateConnector.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/test/plugins/DefaultConstructorThrowsConnector.java
|
scanned
|
file
|
1.8 KB
|
DefaultConstructorThrowsConnector.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/test/plugins/DefaultConstructorThrowsConverter.java
|
scanned
|
file
|
2.4 KB
|
DefaultConstructorThrowsConverter.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/test/plugins/InnocuousSinkConnector.java
|
scanned
|
file
|
2.3 KB
|
InnocuousSinkConnector.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/test/plugins/MissingSuperclassConverter.java
|
scanned
|
file
|
1.6 KB
|
MissingSuperclassConverter.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/test/plugins/NoDefaultConstructorConnector.java
|
scanned
|
file
|
1.8 KB
|
NoDefaultConstructorConnector.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/test/plugins/NoDefaultConstructorConverter.java
|
scanned
|
file
|
2.3 KB
|
NoDefaultConstructorConverter.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/test/plugins/NoDefaultConstructorOverridePolicy.java
|
scanned
|
file
|
1.7 KB
|
NoDefaultConstructorOverridePolicy.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/test/plugins/NonExistentInterface.java
|
scanned
|
file
|
952 bytes
|
NonExistentInterface.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/bad-packaging/test/plugins/OuterClass.java
|
scanned
|
file
|
1.9 KB
|
OuterClass.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/test/plugins/StaticInitializerThrowsConnector.java
|
scanned
|
file
|
1.9 KB
|
StaticInitializerThrowsConnector.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/test/plugins/StaticInitializerThrowsRestExtension.java
|
scanned
|
file
|
1.9 KB
|
StaticInitializerThrowsRestExtension.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/test/plugins/VersionMethodThrowsConnector.java
|
scanned
|
file
|
1.8 KB
|
VersionMethodThrowsConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|