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

["Ivan Majnarić (JIRA)" <ji...@apache.org>]

Ivan Majnarić created KAFKA-6806:
------------------------------------

             Summary: Unable to validate sink connectors without "topics" component which is not required
                 Key: KAFKA-6806
                 URL: https://issues.apache.org/jira/browse/KAFKA-6806
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
    Affects Versions: 1.1.0
         Environment: CP4.1., Centos7
            Reporter: Ivan Majnarić


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:
{code:java}
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",
}{code}
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:
{code:java}
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"
}{code}
So there is a little missmatch of the ways how to validate connectors which I think happened accidentally.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)