Source Connector Task in a distributed env

Hello Team, I am developing a custom Source Connector that watches a given directory for any new files. My question is in a Distributed environment, how will the tasks in different nodes handle the file Queue? Referring to this sample

Re: Source Connector Task in a distributed env

r/kafka-connect-spooldir > > I do not think you can run such a connector in distributed mode though. > Typically something like this runs in standalone mode to avoid conflicts. > > -hans > > > On Wed, Apr 24, 2019 at 1:08 AM Venkata S A wrote: > > > Hello Team, >

Basic KafkaProducer failing

Hello All, I am trying to push some data into a topic using KafkaProducer API. But the initialization is giving a NullPointer Exception.Tried debugging but could not figure it out. Kafka Maven version is 2.2.0 Below is the code & Exception: > import java.util.Properties; > import java.util.Rand