[KAFKA-6806] Unable to validate sink connectors without "topics" component which is not required

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.1.0
• Component/s: connect
• Environment: CP4.1, Centos7
• Assignee: Unassigned
• Reporter: Ivan Majnarić
• Created: 19/Apr/18 13:52
• Updated: 14/Jun/18 15:35

Description

The bug is happening when you try to create new connector through for example kafka-connect-ui.

While both source and sink connectors were able to be validated through REST without "topics" as add-on with "connector.class" like this:

PUT / http://connect-url:8083/connector-plugins/com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector/config/validate
{
    "connector.class": "com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector",
}

In the new version of CP4.1 you still can validate source connectors but not sink connectors. If you want to validate sink connectors you need to add to request -> "topics" config, like:

PUT / http://connect-url:8083/connector-plugins/com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector/config/validate
{
    "connector.class": "com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector",
    "topics": "test-topic"
}

So there is a little missmatch of the ways how to validate connectors which I think happened accidentally.

Issue Links

• relates to: KAFKA-6253 Improve sink connector topic regex validation
• relates to: KAFKA-3073 KafkaConnect should support regular expression for topics