vamossagar12 opened a new pull request, #13726: URL: https://github.com/apache/kafka/pull/13726
AbstractWorkerSourceTask is not enforcing the errors.retry.timeout and errors.retry.delay.max.ms parameters in case of a RetriableException during task.poll(). [KIP-298 ](https://cwiki.apache.org/confluence/display/KAFKA/KIP-298%3A+Error+Handling+in+Connect) explicitly mentions that `poll() in SourceTask will retry in case of RetriableException. The current behaviour is that in case of RetriableException, null is returned immediately. This PR aims to add that support. Note that I think SinkTask#put doesn't honour which can be taken up in a follow up PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
