apache-kafka - 在 ksql 中重新分区多个键

Question

我有一个主题 Say A，它已注册以接受 avro 格式{X VARCHAR, Y INT, Z VARCHAR} and has value {R INT , S VARCHAR, X VARCHAR, Y INT, Z VARCHAR } 的数据，其密钥为{R INT , S VARCHAR, X VARCHAR, Y INT, Z VARCHAR} but key has Z set to null or removed from the key i.e key = {X VARCHAR, Y INT}

我在这里找到了一个解决方案，但这会在连接后将键更改为字符串格式。我正在寻找一种解决方案，它保留了我原来的密钥格式，并且只删除了密钥中的额外属性。

标签： apache-kafkaconfluent-platformksqldb