微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

sqoop-kafka连接到oracle

如何解决sqoop-kafka连接到oracle

我正在尝试使用建立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 举报,一经查实,本站将立刻删除。