|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/java/org/apache/kafka/connect/util
|
scanned
|
directory
|
|
util
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/resources/META-INF
|
scanned
|
directory
|
|
META-INF
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/main/resources/META-INF/services
|
scanned
|
directory
|
|
services
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
test
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect
|
scanned
|
directory
|
|
connect
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/java/org/apache/kafka/connect/connector
|
scanned
|
directory
|
|
connector
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
data
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
header
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
sink
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
source
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
storage
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
util
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/resources/META-INF
|
scanned
|
directory
|
|
META-INF
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/api/src/test/resources/META-INF/services
|
scanned
|
directory
|
|
services
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
basic-auth-extension
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/.gitignore
|
scanned
|
file
|
6 bytes
|
.gitignore
|
|
|
text/plain
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src
|
scanned
|
directory
|
|
src
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main
|
scanned
|
directory
|
|
main
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache/kafka/connect
|
scanned
|
directory
|
|
connect
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest
|
scanned
|
directory
|
|
rest
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic
|
scanned
|
directory
|
|
basic
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth
|
scanned
|
directory
|
|
auth
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
extension
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/resources/META-INF
|
scanned
|
directory
|
|
META-INF
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/main/resources/META-INF/services
|
scanned
|
directory
|
|
services
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
test
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org/apache/kafka/connect
|
scanned
|
directory
|
|
connect
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest
|
scanned
|
directory
|
|
rest
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic
|
scanned
|
directory
|
|
basic
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth
|
scanned
|
directory
|
|
auth
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
extension
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
file
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src
|
scanned
|
directory
|
|
src
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main
|
scanned
|
directory
|
|
main
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java
|
scanned
|
directory
|
|
java
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org
|
scanned
|
directory
|
|
org
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org/apache
|
scanned
|
directory
|
|
apache
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org/apache/kafka
|
scanned
|
directory
|
|
kafka
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org/apache/kafka/connect
|
scanned
|
directory
|
|
connect
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/java/org/apache/kafka/connect/file
|
scanned
|
directory
|
|
file
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
resources
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/resources/META-INF
|
scanned
|
directory
|
|
META-INF
|
|
|
|
|
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/connect/file/src/main/resources/META-INF/services
|
scanned
|
directory
|
|
services
|
|
|
|
|
|
|
|
|
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
|
scanned
|
directory
|
|
test
|
|
|
|
|
|
|
|