[KAFKA-8320] Connect Error handling is using the RetriableException from common package

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 2.0.2, 2.3.0, 2.1.2, 2.2.1
• Component/s: connect
• Assignee: Magesh kumar Nandakumar
• Reporter: Magesh kumar Nandakumar
• Created: 03/May/19 22:00
• Updated: 21/May/19 14:41
• Resolved: 21/May/19 14:41

Description

When a SourceConnector throws 

org.apache.kafka.connect.errors.RetriableException during the poll, connect runtime is supposed to ignore the error and retry per https://cwiki.apache.org/confluence/display/KAFKA/KIP-298%3A+Error+Handling+in+Connect . When the conenctors throw the execption its not handled gracefully. 

WorkerSourceTask is catching the exception from wrong package `org.apache.kafka.common.errors`.  It is not clear from the API standpoint as to which package the connect framework supports. The safest thing would be to support both the packages even though it's less desirable.

Issue Links

• links to: GitHub Pull Request #6675