Mario Molina

Hi. There were multiple changes in the APIs between these version. You could try to use it besides the Kafka version you have deployed

Hi! Yes, you can access to SFTP or FTP server setting its corresponding URI (`ftp://xxxx`)

how did you configure the Avro schema?

If this file is exactly the same, this represents that the offsets were already sent to Kafka to avoid process the same thing over and over again and, consequently, it...

What do you mean by "reset everything"?

Hi @ericbroda! Thanks for your words. What are the filenames you have in that directory? Have you tried with another policy such as Sleepy or Cron policy? What can you...

Can you try with another policy and also change the policy regexp config to this ``policy.regexp=^.*\.txt$``?

Hi @monsterdeeravi You're setting the ``policy.class=com.github.mmolimar.kafka.connect.fs.policy.SleepyPolicy `` and to process files via event notifications you have to use: ``policy.class=com.github.mmolimar.kafka.connect.fs.policy. S3EventNotificationsPolicy``. Let me know if that worked

I think ``policy.s3_event_notifications.queue`` should be ``SQS-queue-name``

You should use ``s3a``. More info [here](https://hadoop.apache.org/docs/current/hadoop-aws/tools/hadoop-aws/index.html).