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)
