search

databricks / iceberg-kafka-connect

Apache License 2.0
219 stars 49 forks source link

Feature: adding default database for dynamic table routing #182

Closed viethungha0610 closed 10 months ago

viethungha0610 commented 10 months ago

Hi team, adding this PR to allow the default database name to be prepended to the values in iceberg.tables.route-field.

This resolves a current issue in Trainline's setup where we have a field to be used for dynamic routing but it doesn't have the database name in it. Previously using this field would have thrown org.apache.iceberg.exceptions.NoSuchTableException: Invalid table identifier: table_name error.