2017-03-20 7 views
1

JDBC Kafkaコネクタのクラスタをセットアップし、同じホスト上で実行されている複数のデータベースからプルするように設定することをお勧めします。JDBC Kafka Connectorは複数のデータベースからデータを取得できますか?

私はKafka Connectのドキュメントを見てきました.1つのデータベースからのみデータを取り出せるようにJDBCコネクタを設定した後に表示されます。

誰でもこれを確認できますか?

答えて

5

モードに応じて、あなたは(スタンドアローンまたは分散)あなたの労働者を起動します。スタンドアロンモードで

、あなたが使用して複数のJDBCコネクタを起動することができます。

bin/connect-standalone worker.properties connector1.properties [connector2.properties connector3.properties ...] 

各connector.properties 1つのデータベースに一致します。ここ

詳細:分散モードRunning workers

、最初のスタート労働者:

$ curl -X POST -H "Content-Type: application/json" --data '{"name": "jdbc-source", "config": {"connector.class":"JdbcSourceConnector", "tasks.max":"1", "connection.url":"jdbc:sqlite:test.db", "topic.prefix":"connect-jdbc-test-", "mode":"bulk" }}' http://worker_host:8083/connectors 

または:

bin/connect-distributed worker.properties 

はその後のようなPOSTのHTTPリクエストで各設定をプッシュします、JSON形式の設定を含むファイルを使用する

$ curl -X POST -H "Content-Type: application/json" --data @config.json http://worker_host:8083/connectors 
関連する問題