[KAFKA-9522] kafka-connect failed when the topic can not be accessed

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 2.3.1
• Component/s: connect
• Assignee: Unassigned
• Reporter: Deblock
• Created: 07/Feb/20 09:07
• Updated: 07/Feb/20 13:00

Description

The kafka-connect fail if the topic can not be join (permission issue or topic doesn't exists).

 

This issue happend using Debezium CDC : https://issues.redhat.com/browse/DBZ-1770

 

The topic can be choosen using a column on the database. If the topic on a database contains an issue (permission issue or topic doesn't exists), the connect stop to work, and new event will not be sent.

 

The exception is thrown  on `WorkerSourceTask` by method `maybeThrowProducerSendException`. Maybe add a parameter to not fail on exception.