You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/06/12 06:41:00 UTC
[jira] [Commented] (KAFKA-6806) Unable to validate sink connectors
without "topics" component which is not required
[ https://issues.apache.org/jira/browse/KAFKA-6806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16509256#comment-16509256 ]
Dong Lin commented on KAFKA-6806:
---------------------------------
Hey [~rhauch], this issue has been marked as blocking issue for 1.1.1 but there does not seem to be person actively working on this. Do you know who will be working on this issue, or do we actually need to block 1.1.1 release until it is fixed?
> 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ć
> Priority: Blocker
> Fix For: 2.0.0, 1.1.1
>
>
> 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)