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で名前プロパティを変更してみてくださいが存在するを実行しようとしているに見えます