search

tabular-io / iceberg-kafka-connect

Apache License 2.0
203 stars 46 forks source link

Issue with Invalid Table Identifier in Kafka Connect #174

Open junsik-gsitm opened 9 months ago

junsik-gsitm commented 9 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 8 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 8 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