|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/header/Header.java
|
scanned
|
file
|
2.4 KB
|
Header.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/header/Headers.java
|
scanned
|
file
|
11.7 KB
|
Headers.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/header/package-info.java
|
scanned
|
file
|
928 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/health/AbstractState.java
|
scanned
|
file
|
3.0 KB
|
AbstractState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/health/ConnectClusterDetails.java
|
scanned
|
file
|
1.2 KB
|
ConnectClusterDetails.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/health/ConnectClusterState.java
|
scanned
|
file
|
3.4 KB
|
ConnectClusterState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorHealth.java
|
scanned
|
file
|
3.4 KB
|
ConnectorHealth.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorState.java
|
scanned
|
file
|
1.7 KB
|
ConnectorState.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/health/ConnectorType.java
|
scanned
|
file
|
1.3 KB
|
ConnectorType.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/health/package-info.java
|
scanned
|
file
|
996 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/health/TaskState.java
|
scanned
|
file
|
2.4 KB
|
TaskState.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtensionContext.java
|
scanned
|
file
|
1.7 KB
|
ConnectRestExtensionContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtension.java
|
scanned
|
file
|
3.6 KB
|
ConnectRestExtension.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/rest/package-info.java
|
scanned
|
file
|
930 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/sink/ErrantRecordReporter.java
|
scanned
|
file
|
2.5 KB
|
ErrantRecordReporter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/sink/package-info.java
|
scanned
|
file
|
949 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnectorContext.java
|
scanned
|
file
|
1.0 KB
|
SinkConnectorContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkConnector.java
|
scanned
|
file
|
4.4 KB
|
SinkConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkRecord.java
|
scanned
|
file
|
11.0 KB
|
SinkRecord.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTaskContext.java
|
scanned
|
file
|
6.6 KB
|
SinkTaskContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/sink/SinkTask.java
|
scanned
|
file
|
9.4 KB
|
SinkTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/ConnectorTransactionBoundaries.java
|
scanned
|
file
|
1.2 KB
|
ConnectorTransactionBoundaries.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/ExactlyOnceSupport.java
|
scanned
|
file
|
1.2 KB
|
ExactlyOnceSupport.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/package-info.java
|
scanned
|
file
|
956 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnectorContext.java
|
scanned
|
file
|
1.3 KB
|
SourceConnectorContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
|
scanned
|
file
|
6.6 KB
|
SourceConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java
|
scanned
|
file
|
5.9 KB
|
SourceRecord.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java
|
scanned
|
file
|
3.7 KB
|
SourceTaskContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java
|
scanned
|
file
|
6.7 KB
|
SourceTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/source/TransactionContext.java
|
scanned
|
file
|
3.3 KB
|
TransactionContext.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterConfig.java
|
scanned
|
file
|
2.4 KB
|
ConverterConfig.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/Converter.java
|
scanned
|
file
|
4.9 KB
|
Converter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/ConverterType.java
|
scanned
|
file
|
1.9 KB
|
ConverterType.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/HeaderConverter.java
|
scanned
|
file
|
3.2 KB
|
HeaderConverter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/OffsetStorageReader.java
|
scanned
|
file
|
2.8 KB
|
OffsetStorageReader.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/package-info.java
|
scanned
|
file
|
949 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java
|
scanned
|
file
|
3.3 KB
|
SimpleHeaderConverter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverterConfig.java
|
scanned
|
file
|
2.2 KB
|
StringConverterConfig.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/storage/StringConverter.java
|
scanned
|
file
|
4.7 KB
|
StringConverter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/transforms/package-info.java
|
scanned
|
file
|
936 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/package-info.java
|
scanned
|
file
|
1008 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/Predicate.java
|
scanned
|
file
|
2.6 KB
|
Predicate.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/transforms/Transformation.java
|
scanned
|
file
|
3.1 KB
|
Transformation.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/util/ConnectorUtils.java
|
scanned
|
file
|
2.6 KB
|
ConnectorUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/util/package-info.java
|
scanned
|
file
|
921 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.Converter
|
scanned
|
file
|
841 bytes
|
org.apache.kafka.connect.storage.Converter
|
.Converter
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter
|
scanned
|
file
|
896 bytes
|
org.apache.kafka.connect.storage.HeaderConverter
|
.HeaderConverter
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorReconfigurationTest.java
|
scanned
|
file
|
2.6 KB
|
ConnectorReconfigurationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/connector/ConnectorTest.java
|
scanned
|
file
|
2.9 KB
|
ConnectorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/ConnectSchemaTest.java
|
scanned
|
file
|
24.7 KB
|
ConnectSchemaTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/DateTest.java
|
scanned
|
file
|
3.1 KB
|
DateTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/DecimalTest.java
|
scanned
|
file
|
2.4 KB
|
DecimalTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/FakeSchema.java
|
scanned
|
file
|
1.8 KB
|
FakeSchema.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/FieldTest.java
|
scanned
|
file
|
1.6 KB
|
FieldTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/SchemaBuilderTest.java
|
scanned
|
file
|
14.6 KB
|
SchemaBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/SchemaProjectorTest.java
|
scanned
|
file
|
24.7 KB
|
SchemaProjectorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/StructTest.java
|
scanned
|
file
|
13.0 KB
|
StructTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/TimestampTest.java
|
scanned
|
file
|
2.8 KB
|
TimestampTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/TimeTest.java
|
scanned
|
file
|
3.2 KB
|
TimeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/data/ValuesTest.java
|
scanned
|
file
|
56.5 KB
|
ValuesTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/header/ConnectHeadersTest.java
|
scanned
|
file
|
22.7 KB
|
ConnectHeadersTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/header/ConnectHeaderTest.java
|
scanned
|
file
|
3.6 KB
|
ConnectHeaderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/sink/SinkConnectorTest.java
|
scanned
|
file
|
4.7 KB
|
SinkConnectorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/sink/SinkRecordTest.java
|
scanned
|
file
|
7.6 KB
|
SinkRecordTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/source/SourceConnectorTest.java
|
scanned
|
file
|
4.9 KB
|
SourceConnectorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/source/SourceRecordTest.java
|
scanned
|
file
|
5.9 KB
|
SourceRecordTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/storage/ConverterTypeTest.java
|
scanned
|
file
|
1.1 KB
|
ConverterTypeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/storage/SimpleHeaderConverterTest.java
|
scanned
|
file
|
9.4 KB
|
SimpleHeaderConverterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/storage/StringConverterTest.java
|
scanned
|
file
|
4.2 KB
|
StringConverterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/util/ConnectorUtilsTest.java
|
scanned
|
file
|
2.3 KB
|
ConnectorUtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector
|
scanned
|
file
|
858 bytes
|
org.apache.kafka.connect.sink.SinkConnector
|
.SinkConnector
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector
|
scanned
|
file
|
864 bytes
|
org.apache.kafka.connect.source.SourceConnector
|
.SourceConnector
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtension.java
|
scanned
|
file
|
5.4 KB
|
BasicAuthSecurityRestExtension.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java
|
scanned
|
file
|
8.4 KB
|
JaasBasicAuthFilter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/PropertyFileLoginModule.java
|
scanned
|
file
|
6.3 KB
|
PropertyFileLoginModule.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/resources/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension
|
scanned
|
file
|
874 bytes
|
org.apache.kafka.connect.rest.ConnectRestExtension
|
.ConnectRestExtension
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/BasicAuthSecurityRestExtensionTest.java
|
scanned
|
file
|
4.8 KB
|
BasicAuthSecurityRestExtensionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilterTest.java
|
scanned
|
file
|
11.9 KB
|
JaasBasicAuthFilterTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java
|
scanned
|
file
|
3.2 KB
|
FileStreamSinkConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkTask.java
|
scanned
|
file
|
3.4 KB
|
FileStreamSinkTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java
|
scanned
|
file
|
6.9 KB
|
FileStreamSourceConnector.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceTask.java
|
scanned
|
file
|
9.5 KB
|
FileStreamSourceTask.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/resources/META-INF/services/org.apache.kafka.connect.sink.SinkConnector
|
scanned
|
file
|
846 bytes
|
org.apache.kafka.connect.sink.SinkConnector
|
.SinkConnector
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/resources/META-INF/services/org.apache.kafka.connect.source.SourceConnector
|
scanned
|
file
|
848 bytes
|
org.apache.kafka.connect.source.SourceConnector
|
.SourceConnector
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkConnectorTest.java
|
scanned
|
file
|
3.8 KB
|
FileStreamSinkConnectorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSinkTaskTest.java
|
scanned
|
file
|
4.3 KB
|
FileStreamSinkTaskTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceConnectorTest.java
|
scanned
|
file
|
10.6 KB
|
FileStreamSourceConnectorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/test/java/org/apache/kafka/connect/file/FileStreamSourceTaskTest.java
|
scanned
|
file
|
9.3 KB
|
FileStreamSourceTaskTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/test/java/org/apache/kafka/connect/file/integration/FileStreamSinkConnectorIntegrationTest.java
|
scanned
|
file
|
8.5 KB
|
FileStreamSinkConnectorIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/test/java/org/apache/kafka/connect/file/integration/FileStreamSourceConnectorIntegrationTest.java
|
scanned
|
file
|
9.7 KB
|
FileStreamSourceConnectorIntegrationTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/test/resources/log4j2.yaml
|
scanned
|
file
|
1.1 KB
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/main/java/org/apache/kafka/connect/json/DecimalFormat.java
|
scanned
|
file
|
1.3 KB
|
DecimalFormat.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverterConfig.java
|
scanned
|
file
|
7.0 KB
|
JsonConverterConfig.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java
|
scanned
|
file
|
35.4 KB
|
JsonConverter.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java
|
scanned
|
file
|
2.9 KB
|
JsonDeserializer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/main/java/org/apache/kafka/connect/json/JsonSchema.java
|
scanned
|
file
|
4.2 KB
|
JsonSchema.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/main/java/org/apache/kafka/connect/json/JsonSerializer.java
|
scanned
|
file
|
2.7 KB
|
JsonSerializer.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.Converter
|
scanned
|
file
|
836 bytes
|
org.apache.kafka.connect.storage.Converter
|
.Converter
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/main/resources/META-INF/services/org.apache.kafka.connect.storage.HeaderConverter
|
scanned
|
file
|
836 bytes
|
org.apache.kafka.connect.storage.HeaderConverter
|
.HeaderConverter
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/json/src/test/java/org/apache/kafka/connect/json/JsonConverterConfigTest.java
|
scanned
|
file
|
1.6 KB
|
JsonConverterConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|