#3212·automq

[Feature Request] Alias name for Table topic for Iceberg table Identifier

Author: ameyam1Created Feb 8, 2026Updated Sep 16, 2026
Labelsenhancement

Who is this feature for?

Engineers consuming Iceberg table topic have to handle the quirky topic names as table name

What problem are they facing today?

Engineers consuming Iceberg table topic have to handle the "kafka.mytopic.v1" as table name It would be beneficial to provide alias table name to handle quirky topic names and rename them to standardized table name in datalakes Ex. kafka.mytopic.v1 -> mykafkatable

Why is solving this impactful?

  • Writing queries in Iceberg on table topics becomes very difficult to add backticks ``.
  • Migration from Kafka + Spark Streaming to AutoMQ be more efficient with same table names rather than having kafka topic name in Datalake
  • In Kafka, typical topic are named as ".v1" (dot version number) which makes confusing table names.

Proposed solution

  • Additional config during inside table topic creation
java
public static final String TABLE_TOPIC_OVERRIDE_NAME = "automq.table.topic.overridename";
  • Changing table identifier utility code
java
public class TableIdentifierUtil {
    public static TableIdentifier of(String namespace, String name, String overrideName) {
        String tableName = StringUtils.isBlank(overrideName)?  overrideName : name; 
        if (StringUtils.isBlank(namespace)) {
            return TableIdentifier.of(tableName);
        } else {
            return TableIdentifier.of(namespace, tableName);
        }
    }
}

Additional notes

No response