sqoop-kafka connector to oracle

259 Views Asked by At

I am trying to make oracle-kafka connection with . There is a sqoop-kafka connector in this website, but documentation here is https://sqoop.apache.org/docs/1.99.7/user/connectors/Connector-Kafka.html but there is not clean explanation in this documantation and also anywhere. And I am stuck on this problem. I know there are connectors for oracle and kafka but I am trying in this way.

sqoop import --connect "jdbc:oracle:thin:@IP:1521/dbname --username user --password pass --table result --topic testing

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

and also I tried this and I also get error

sqoop import --connect "jdbc:oracle:thin:@IP:1521/dbname --username user --password pass --table result --broker-list IP --topic testing

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

There are 1 best solutions below

2
Iskuskov Alexander On

Try to add quote to the end of connection string:

"jdbc:oracle:thin:@IP:1521/dbname"