如何解决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”
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。