search

tabular-io / iceberg-kafka-connect

Apache License 2.0
171 stars 31 forks source link

Feature: adding default database for dynamic table routing #182

Closed viethungha0610 closed 5 months ago

viethungha0610 commented 5 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.