[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
public static final String TABLE_TOPIC_OVERRIDE_NAME = "automq.table.topic.overridename";- Changing table identifier utility code
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
Source: AutoMQ/automq