4.0.0 io.streamthoughts kafka-connect-filepulse-reactor 2.14.1 kafka-connect-filepulse-plugin Kafka Connect Source File Pulse Plugin ${project.parent.basedir} ${project.parent.basedir}/header src/main/resources true org.apache.maven.plugins maven-jar-plugin org.apache.maven.plugins maven-surefire-plugin integration org.apache.maven.plugins maven-failsafe-plugin integration ${project.build.outputDirectory} integration-test integration-test verify org.codehaus.mojo build-helper-maven-plugin 3.4.0 add-integration-test-source generate-test-sources add-test-source src/integration-test/java add-integration-test-resource generate-test-resources add-test-resource src/integration-test/resources org.apache.maven.plugins maven-assembly-plugin src/assembly/development.xml src/assembly/package.xml make-assembly package single test-make-assembly pre-integration-test single org.apache.httpcomponents httpclient 4.5.14 dist io.confluent ${kafka.connect.maven.plugin.version} kafka-connect-maven-plugin kafka-connect kafka-connect-file-pulse https://github.com/streamthoughts/kafka-connect-file-pulse https://github.com/streamthoughts/kafka-connect-file-pulse The Kafka Connect FilePulse Connector is a powerful source connector that makes it easy to parse, transform, and load data from the local filesystem, Amazon S3, Azure Blob Storage and Google Cloud Storage. This connector supports a variety of formats equally for all storage systems, e.g., text files, CSV, XML, JSON, Avro, Log4j, etc. StreamThoughts This connector is supported by the open source community. https://streamthoughts.io/open-source ${project.basedir}/../assets/logo.png streamthoughts organization StreamThoughts https://streamthoughts.io/ source filesystem files grok parsing log csv xml cloud aws azure gcs sftp atLeastOnce true standalone maven-assembly-plugin src/assembly/standalone.xml all true io.streamthoughts kafka-connect-filepulse-amazons3-fs ${project.version} io.streamthoughts kafka-connect-filepulse-azure-storage-fs ${project.version} io.streamthoughts kafka-connect-filepulse-google-cloud-storage-fs ${project.version} io.streamthoughts kafka-connect-filepulse-local-fs ${project.version} io.streamthoughts kafka-connect-filepulse-sftp-fs ${project.version} io.streamthoughts kafka-connect-filepulse-aliyunoss-fs ${project.version} aws io.streamthoughts kafka-connect-filepulse-amazons3-fs ${project.version} gcs io.streamthoughts kafka-connect-filepulse-google-cloud-storage-fs ${project.version} azure io.streamthoughts kafka-connect-filepulse-azure-storage-fs ${project.version} local io.streamthoughts kafka-connect-filepulse-local-fs ${project.version} io.streamthoughts kafka-connect-filepulse-api ${project.version} io.streamthoughts kafka-connect-filepulse-filters ${project.version} com.jsoniter jsoniter org.apache.kafka kafka-clients provided org.apache.kafka connect-api provided commons-io commons-io io.confluent kafka-schema-registry-client org.mockito mockito-core org.slf4j slf4j-log4j12 org.testcontainers testcontainers org.testcontainers junit-jupiter test io.rest-assured rest-assured io.rest-assured json-path io.streamthoughts kafka-connect-filepulse-local-fs ${project.version} test