我想改变模式插入PostgreSQL依赖于值消息当我生产者消息Kafka连接？我该怎么做？我试着将每个主题用于不同的架构类型，但这不是我想要的。例如：主题名称：国家_城市{ cityId: 1 }将插入模式：country_1 { cityId: 2 }将插入到模式中：国家2
{ cityId: 1 }
{ cityId: 2 }
toiithl61#
所使用的模式/表完全取决于主题名称，而不是每个记录中的值。您需要使用Kafka连接转换来覆盖“传出主题名称”，以控制数据写入数据库的位置。但是，如果您的数据库中有编号的表，那么这很可能是一个反模式，您应该使用关系来代替。
1条答案
按热度按时间toiithl61#
所使用的模式/表完全取决于主题名称，而不是每个记录中的值。
您需要使用Kafka连接转换来覆盖“传出主题名称”，以控制数据写入数据库的位置。
但是，如果您的数据库中有编号的表，那么这很可能是一个反模式，您应该使用关系来代替。