sqoop-kafka连接到oracle

问题描述

我正在尝试使用sqoop建立oracle-kafka连接。 website中有一个sqoop-kafka连接器，但是此处的文档是https://sqoop.apache.org/docs/1.99.7/user/connectors/Connector-Kafka.html，但是在此文档以及任何地方都没有明确的解释。我被困在这个问题上。我知道有用于oracle和kafka的连接器，但是我正在尝试这种方式。

sqoop导入--connect“ jdbc：oracle：thin：@IP：1521 / dbname --username用户--password传递--table结果--topic测试

ERROR tool.BaseSqoopTool: Error parsing arguments for import:
ERROR tool.BaseSqoopTool: Unrecognized argument: --topic
ERROR tool.BaseSqoopTool: Unrecognized argument: test

我也尝试过这个，但是我也得到了错误

sqoop import --connect“ jdbc：oracle：thin：@IP：1521 / dbname --username用户--password pass --table结果--broker-list IP --topic测试

ERROR tool.BaseSqoopTool: Error parsing arguments for import:
ERROR tool.BaseSqoopTool: Unrecognized argument: --broker-list
ERROR tool.BaseSqoopTool: Unrecognized argument: testing

解决方法

尝试在连接字符串的末尾添加引号：

“ jdbc：oracle：thin：@IP：1521 / dbname”

apache-kafka sqoop2