本地系统中的kafka导入/导出数据答案

【问题标题】：kafka import/export data in local system本地系统中的kafka导入/导出数据
【发布时间】：2017-09-16 12:16:36
【问题描述】：

当我尝试使用 kafka 导入/导出数据时。我跑了一个查询

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

但我得到错误

错误无法为 config/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：连接器本地文件已存在在 org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:80) 在 org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:67) 在 org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:97) 引起：org.apache.kafka.connect.errors.AlreadyExistsException：连接器本地文件已经存在在 org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig（StandaloneHerder.java:145）在 org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:94)。

请帮我解决这个问题？

【问题讨论】：

标签： hadoop apache-kafka bigdata

【解决方案1】：

看起来您尝试在此工作器中运行的两个连接器具有相同的连接器名称

连接器本地文件已存在

尝试更改其中一个连接器配置文件中的名称属性。

【讨论】：