search

databricks / iceberg-kafka-connect

Apache License 2.0
219 stars 49 forks source link

Issue with Invalid Table Identifier in Kafka Connect #174

Open junsik-gsitm opened 11 months ago

junsik-gsitm commented 11 months ago

I'm encountering an issue with the following error message:

Caused by: java.lang.IllegalArgumentException: Invalid table identifier: mongodemo.tripNotification

I previously faced this same error while using the MySQL source connector, but I managed to resolve it. Now, I'm attempting to use the MongoDB source connector and have encountered the "Invalid table identifier" error again.

I'm using the "connector.class": "com.mongodb.kafka.connect.MongoSourceConnector". I'm not sure why this issue is occurring. Could you please provide some assistance or guidance on how to resolve this?

bryanck commented 10 months ago

Does that Iceberg namespace and table exist in your catalog, and are you using auto table creation? It would be helpful if you post your connector config.

mattssll commented 10 months ago

I had similar issues by creating table when the catalog table was not present in table name, as bryanck said, check that the mongodemo schema exists in your catalog