SourceTask lifecycle - can start() be called more than once?

Kafka Connect
1

Hi!

Is it possible for the Kafka Connect framework to call a SourceConnector instance’s start() method more than once?

I ask because I’m looking into an issue where the framework appears to be calling stop() before start() completes; the locking code to work around this will be simpler if we can assume start() is never called more than once.

Thanks,
David

2

the framework appears to be calling stop() before start() completes

Upon closer inspection of our connector code, there’s an alternate explanation for the race we’re looking at. So I guess a second question would be:

Should a SourceTask be prepared to handle a stop() request before start() returns?