bugfix> sql-server > 投稿

ここにあるドッカー画像があります https://github.com/Landoop/fast-data-dev 私が開発に使用しているすべての良いものがあります。 JDBCコネクタを追加してKafkaトピックにプッシュしようとしましたが、このエラーが発生しています。私はうまく動作しているJavaでコンシューマを作成しましたが、KafkaConnectを使用したいと思います

Invalid value java.sql.SQLException: No suitable driver found for jdbc:sqlserver://servername for configuration Couldn't open connection to jdbc:sqlserver://servername

name=JdbcSourceConnector
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
connection.user=user
connection.password=password
tasks.max=1
connection.url=jdbc:sqlserver://servername
topic.prefix=test
table.whitelist=dbo.IB_WEBLOG_DUMMY_small
query=SELECT * FROM IB_WEBLOG_DUMMY_small
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter=org.apache.kafka.connect.json.JsonConverter
poll.interval.ms=5000
table.poll.interval.ms=120000
mode=bulk

この問題を解決するために何を検討すべきですか?

回答 1 件
  • JDBCドライバーのJARファイルがKafka Connectのクラスパスにありません。それをそこに置いて、あなたは行くのが良いでしょう:

    One option is to install the JDBC driver jar alongside the connector. The packaged connector is installed in the share/java/kafka-connect-jdbc  インストールディレクトリに相対的なディレクトリ。 DebianまたはRPMパッケージからインストールした場合、コネクタは /usr/share/java/kafka-connect-jdbc にインストールされます 。 zipまたはtarファイルからインストールした場合、コネクタは、Confluent Platformアーカイブを解凍したディレクトリの下の上記のパスにインストールされます。

         

    あるいは、connect-standaloneまたはconnect-distributedを実行する前に、CLASSPATH変数を設定できます。例えば:

         

    $ CLASSPATH=/usr/local/firebird/* ./bin/connect-distributed ./config/connect-distributed.properties

    または、すべてのSQL Server JDBC JARファイルを libs に配置します  Apache Kafkaのルートフォルダーの下のディレクトリ。しかし、それはクラスパスを汚染するため、本番環境では避けるべきです。

あなたの答え