卡夫卡连接会在0.9版本的工作任务在0.10.2

不工作，当我运行我的卡夫卡连接的工作，我得到以下卡夫卡连接会在0.9版本的工作任务在0.10.2

[2017-04-25 14:56:22,806] ERROR Failed to create job for ./etc/kafka-connect-jdbc/sqlserver.properties (org.apache.kafka.connect.cli.ConnectStandalone:88) 
[2017-04-25 14:56:22,808] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:99) 
java.util.concurrent.ExecutionException: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid (use the endpoint `/{connectorType}/config/validate` to get a full list of errors) 
    at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:80) 
    at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:67) 
    at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:96) 
Caused by: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: 
Connector configuration is invalid (use the endpoint `/{connectorType}/config/validate` to get a full list of errors) 
    at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:161) 
    at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:93)

我的属性文件中的错误是

name=test-sqlserver-jdbc-autoincrement 
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector 
tasks.max=1 
connection.url=jdbc:sqlserver://192.168.9.142:1433;databaseName=postilion;user=elasticsearch;password=elasticsearch 
query=select convert(varchar(10), date_time, 120) as date,convert(char(12), 
date_time, 114) as time, * from support_notifications 
mode=timestamp+incrementing 
timestamp.column.name=date_time 
incrementing.column.name=event_nr 
topic.prefix=test-events

我试图做GET使用curl http://localhost:8083 /JdbcSourceConnector/config/validate调用kafka connect（在崩溃之前），我得到的响应为{"version":"0.10.2.0-cp1","commit":"64c9b42f3319cdc9"}curl: (3) <url> malformed。任何想法我做错了，因为这项工作在卡夫卡0.9工作。

来源

2017-04-25 Zigmaphi

卡夫卡0.10.2.0了有关配置验证它没有报告的实际问题......我们0.10.2.1昨日发布和错误，这应该解决这个问题（28其他错误）。试一试。 –

@Zigmaphi由于请求中的“8083”和“/ JdbcSourceConnector”之间有一个空格，因此您需要响应'curl http：// localhost：8083/JdbcSourceConnector/config/validate'。您应该得到类似于“{0}的错误代码”：400, “消息”：“Connector config {}不包含连接器类型” } –

所以我找到了一条出路。我结束了从时间戳改变模式 +递增到递增在属性文件中，除去线路timestamp.column.name = DATE_TIME。属性文件现在看起来像这样

name=test-sqlserver-jdbc-autoincrement 
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector 
tasks.max=1 
connection.url=jdbc:sqlserver://192.168.9.142:1433;databaseName=postilion;user=elasticsearch;password=elasticsearch 
query=select convert(varchar(10), date_time, 120) as date,convert(char(12), date_time, 114) as time, * from support_notifications 
mode=incrementing 
incrementing.column.name=event_nr 
topic.prefix=postilion-events

来源

2017-04-26 06:39:24 Zigmaphi

卡夫卡连接会在0.9版本的工作任务在0.10.2

回答

相关问题