|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/runtime/src/test/resources/test-plugins/classpath-converter/org/apache/kafka/connect/converters/ByteArrayConverter.java
|
scanned
|
file
|
3.3 KB
|
ByteArrayConverter.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/multiple-plugins-in-jar/test/plugins/ThingOne.java
|
scanned
|
file
|
1.7 KB
|
ThingOne.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/multiple-plugins-in-jar/test/plugins/ThingTwo.java
|
scanned
|
file
|
1.7 KB
|
ThingTwo.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/non-migrated/test/plugins/NonMigratedConverter.java
|
scanned
|
file
|
1.6 KB
|
NonMigratedConverter.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/non-migrated/test/plugins/NonMigratedHeaderConverter.java
|
scanned
|
file
|
1.8 KB
|
NonMigratedHeaderConverter.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/non-migrated/test/plugins/NonMigratedMultiPlugin.java
|
scanned
|
file
|
2.8 KB
|
NonMigratedMultiPlugin.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/non-migrated/test/plugins/NonMigratedPredicate.java
|
scanned
|
file
|
1.5 KB
|
NonMigratedPredicate.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/non-migrated/test/plugins/NonMigratedSinkConnector.java
|
scanned
|
file
|
1.7 KB
|
NonMigratedSinkConnector.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/non-migrated/test/plugins/NonMigratedSourceConnector.java
|
scanned
|
file
|
1.7 KB
|
NonMigratedSourceConnector.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/non-migrated/test/plugins/NonMigratedTransformation.java
|
scanned
|
file
|
1.5 KB
|
NonMigratedTransformation.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/read-version-from-resource-v1/test/plugins/ReadVersionFromResource.java
|
scanned
|
file
|
3.3 KB
|
ReadVersionFromResource.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/read-version-from-resource-v2/test/plugins/ReadVersionFromResource.java
|
scanned
|
file
|
3.3 KB
|
ReadVersionFromResource.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/sampling-config-provider/test/plugins/SamplingConfigProvider.java
|
scanned
|
file
|
3.3 KB
|
SamplingConfigProvider.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/sampling-configurable/test/plugins/SamplingConfigurable.java
|
scanned
|
file
|
2.8 KB
|
SamplingConfigurable.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/sampling-connector/test/plugins/SamplingConnector.java
|
scanned
|
file
|
2.9 KB
|
SamplingConnector.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/sampling-converter/test/plugins/SamplingConverter.java
|
scanned
|
file
|
2.7 KB
|
SamplingConverter.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/sampling-header-converter/test/plugins/SamplingHeaderConverter.java
|
scanned
|
file
|
3.0 KB
|
SamplingHeaderConverter.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/service-loader/test/plugins/ServiceLoadedClass.java
|
scanned
|
file
|
1.4 KB
|
ServiceLoadedClass.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/service-loader/test/plugins/ServiceLoadedSubclass.java
|
scanned
|
file
|
1.3 KB
|
ServiceLoadedSubclass.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/service-loader/test/plugins/ServiceLoaderPlugin.java
|
scanned
|
file
|
2.8 KB
|
ServiceLoaderPlugin.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/subclass-of-classpath/test/plugins/SubclassOfClasspathConverter.java
|
scanned
|
file
|
1.2 KB
|
SubclassOfClasspathConverter.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/subclass-of-classpath/test/plugins/SubclassOfClasspathOverridePolicy.java
|
scanned
|
file
|
1.3 KB
|
SubclassOfClasspathOverridePolicy.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/versioned-converter/test/plugins/VersionedConverter.java
|
scanned
|
file
|
2.4 KB
|
VersionedConverter.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/versioned-header-converter/test/plugins/VersionedHeaderConverter.java
|
scanned
|
file
|
2.5 KB
|
VersionedHeaderConverter.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/versioned-predicate/test/plugins/VersionedPredicate.java
|
scanned
|
file
|
2.3 KB
|
VersionedPredicate.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/versioned-sink-connector/test/plugins/VersionedSinkConnector.java
|
scanned
|
file
|
3.2 KB
|
VersionedSinkConnector.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/versioned-source-connector/test/plugins/VersionedSourceConnector.java
|
scanned
|
file
|
3.2 KB
|
VersionedSourceConnector.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/versioned-transformation/test/plugins/VersionedTransformation.java
|
scanned
|
file
|
2.3 KB
|
VersionedTransformation.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockConnector.java
|
scanned
|
file
|
4.0 KB
|
MockConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockSinkConnector.java
|
scanned
|
file
|
2.4 KB
|
MockSinkConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockSinkTask.java
|
scanned
|
file
|
3.1 KB
|
MockSinkTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockSourceConnector.java
|
scanned
|
file
|
2.4 KB
|
MockSourceConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/MockSourceTask.java
|
scanned
|
file
|
2.5 KB
|
MockSourceTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/package-info.java
|
scanned
|
file
|
917 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/SchemaSourceConnector.java
|
scanned
|
file
|
2.2 KB
|
SchemaSourceConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/SchemaSourceTask.java
|
scanned
|
file
|
6.6 KB
|
SchemaSourceTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkConnector.java
|
scanned
|
file
|
2.1 KB
|
VerifiableSinkConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSinkTask.java
|
scanned
|
file
|
4.5 KB
|
VerifiableSinkTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceConnector.java
|
scanned
|
file
|
2.1 KB
|
VerifiableSourceConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/test-plugins/src/main/java/org/apache/kafka/connect/tools/VerifiableSourceTask.java
|
scanned
|
file
|
6.7 KB
|
VerifiableSourceTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java
|
scanned
|
file
|
20.4 KB
|
Cast.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/DropHeaders.java
|
scanned
|
file
|
2.9 KB
|
DropHeaders.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java
|
scanned
|
file
|
5.9 KB
|
ExtractField.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/FieldSyntaxVersion.java
|
scanned
|
file
|
4.1 KB
|
FieldSyntaxVersion.java
|
.java
|
Java
|
text/html
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/field/SingleFieldPath.java
|
scanned
|
file
|
9.0 KB
|
SingleFieldPath.java
|
.java
|
Java
|
text/html
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Filter.java
|
scanned
|
file
|
2.1 KB
|
Filter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Flatten.java
|
scanned
|
file
|
12.8 KB
|
Flatten.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HeaderFrom.java
|
scanned
|
file
|
10.6 KB
|
HeaderFrom.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HoistField.java
|
scanned
|
file
|
5.0 KB
|
HoistField.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertField.java
|
scanned
|
file
|
12.2 KB
|
InsertField.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertHeader.java
|
scanned
|
file
|
3.1 KB
|
InsertHeader.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/MaskField.java
|
scanned
|
file
|
9.2 KB
|
MaskField.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java
|
scanned
|
file
|
2.6 KB
|
HasHeaderKey.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/RecordIsTombstone.java
|
scanned
|
file
|
2.0 KB
|
RecordIsTombstone.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java
|
scanned
|
file
|
3.2 KB
|
TopicNameMatches.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/RegexRouter.java
|
scanned
|
file
|
3.6 KB
|
RegexRouter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java
|
scanned
|
file
|
9.6 KB
|
ReplaceField.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/SetSchemaMetadata.java
|
scanned
|
file
|
7.8 KB
|
SetSchemaMetadata.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java
|
scanned
|
file
|
22.3 KB
|
TimestampConverter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampRouter.java
|
scanned
|
file
|
4.4 KB
|
TimestampRouter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidator.java
|
scanned
|
file
|
1.3 KB
|
NonEmptyListValidator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/RegexValidator.java
|
scanned
|
file
|
1.4 KB
|
RegexValidator.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/Requirements.java
|
scanned
|
file
|
2.8 KB
|
Requirements.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
|
scanned
|
file
|
1.7 KB
|
SchemaUtil.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util/SimpleConfig.java
|
scanned
|
file
|
1.2 KB
|
SimpleConfig.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ValueToKey.java
|
scanned
|
file
|
5.2 KB
|
ValueToKey.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/CastTest.java
|
scanned
|
file
|
27.7 KB
|
CastTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/DropHeadersTest.java
|
scanned
|
file
|
4.7 KB
|
DropHeadersTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ExtractFieldTest.java
|
scanned
|
file
|
9.9 KB
|
ExtractFieldTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/FieldPathNotationTest.java
|
scanned
|
file
|
6.2 KB
|
FieldPathNotationTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/FieldSyntaxVersionTest.java
|
scanned
|
file
|
3.2 KB
|
FieldSyntaxVersionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/field/SingleFieldPathTest.java
|
scanned
|
file
|
4.5 KB
|
SingleFieldPathTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/FlattenTest.java
|
scanned
|
file
|
16.8 KB
|
FlattenTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/HeaderFromTest.java
|
scanned
|
file
|
19.6 KB
|
HeaderFromTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/HoistFieldTest.java
|
scanned
|
file
|
3.1 KB
|
HoistFieldTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertFieldTest.java
|
scanned
|
file
|
11.3 KB
|
InsertFieldTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertHeaderTest.java
|
scanned
|
file
|
4.9 KB
|
InsertHeaderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/MaskFieldTest.java
|
scanned
|
file
|
12.4 KB
|
MaskFieldTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKeyTest.java
|
scanned
|
file
|
4.0 KB
|
HasHeaderKeyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatchesTest.java
|
scanned
|
file
|
3.7 KB
|
TopicNameMatchesTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/RegexRouterTest.java
|
scanned
|
file
|
2.5 KB
|
RegexRouterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ReplaceFieldTest.java
|
scanned
|
file
|
7.4 KB
|
ReplaceFieldTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/SetSchemaMetadataTest.java
|
scanned
|
file
|
8.7 KB
|
SetSchemaMetadataTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampConverterTest.java
|
scanned
|
file
|
34.0 KB
|
TimestampConverterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/TimestampRouterTest.java
|
scanned
|
file
|
1.9 KB
|
TimestampRouterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidatorTest.java
|
scanned
|
file
|
1.5 KB
|
NonEmptyListValidatorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/transforms/src/test/java/org/apache/kafka/connect/transforms/ValueToKeyTest.java
|
scanned
|
file
|
5.2 KB
|
ValueToKeyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorEvent.java
|
scanned
|
file
|
1.4 KB
|
CoordinatorEvent.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorEventProcessor.java
|
scanned
|
file
|
1.6 KB
|
CoordinatorEventProcessor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutorImpl.java
|
scanned
|
file
|
4.9 KB
|
CoordinatorExecutorImpl.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorExecutor.java
|
scanned
|
file
|
2.6 KB
|
CoordinatorExecutor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorLoaderImpl.java
|
scanned
|
file
|
15.9 KB
|
CoordinatorLoaderImpl.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorLoader.java
|
scanned
|
file
|
1.8 KB
|
CoordinatorLoader.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetadataDelta.java
|
scanned
|
file
|
2.1 KB
|
CoordinatorMetadataDelta.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetadataImage.java
|
scanned
|
file
|
2.7 KB
|
CoordinatorMetadataImage.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetrics.java
|
scanned
|
file
|
2.9 KB
|
CoordinatorMetrics.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorMetricsShard.java
|
scanned
|
file
|
1.9 KB
|
CoordinatorMetricsShard.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorOperationExceptionHelper.java
|
scanned
|
file
|
3.6 KB
|
CoordinatorOperationExceptionHelper.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorPlayback.java
|
scanned
|
file
|
2.5 KB
|
CoordinatorPlayback.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRecord.java
|
scanned
|
file
|
3.2 KB
|
CoordinatorRecord.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|