2017-05-11 5 views
0

kafkaを使用してデータをインポート/エクスポートしようとします。私はクエリを実行しましたkafkaローカルシステムのインポート/エクスポートデータ

bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-source.properties

しかし、私は

ERRORが設定/ connect-file-sink.properties(org.apache.kafka.connect.cli.ConnectStandalone:89)のためのジョブを作成できませんでしたエラーを取得し [2017-05- 10 21:26:49,110]エラーコネクタエラー(org.apache.kafka.connect.cli.ConnectStandalone:100)の後で停止する java.util.concurrent.ExecutionException:org.apache.kafka.connect.errors.AlreadyExistsException:コネクタローカル-fileはすでに存在しています at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:80) at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureC allback.java:67) at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:97) 原因:org.apache.kafka.connect.errors.AlreadyExistsException:コネクタのローカルファイルが既に存在する at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:145) at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:94)。

これを解決するために私を助けてください。それはあなたが2つのコネクタの同じコネクタの名前を持っているようにあなたは、この作業員に

コネクターローカル・ファイルが既に

1で名前プロパティを変更してみてくださいが存在するを実行しようとしているに見えます

答えて

0

あなたのコネクター構成ファイルの

関連する問題