如何在kafka或ksql中修改或添加主题键

rlcwz9us 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(364)

我有很多主题都是在没有密钥的情况下创建的，如何修改它们并添加合适的主题？
我需要改变一些连接器，希望他们能够正确阅读这个主题
我个人使用ksql，但我没有找到任何方法

1条答案

键被添加到记录中，而不是主题中。你可以简单地用键开始写你的记录。
不能向已发布的记录添加键，因为kafka日志是不可变的。为了做到这一点，您可以使用包含未知记录的主题中的数据，并在每个记录中设置一个键，然后将它们重新发布到另一个主题。
您可以通过ksql使用 PARTITION BY 声明：

CREATE STREAM KEYED_STREAM as \
  SELECT * FROM UNKEYED_STREAM PARTITION BY <key column>;