0

我创建了很多没有密钥的主题,我如何修改它们并添加正确的主题?

我需要为一些希望它们正确阅读主题的连接器更改此设置

我个人使用 ksql 但我没有找到任何方法

4

1 回答 1

5

键被添加到记录,而不是主题。你可以简单地开始用钥匙写你的记录。

您不能将密钥添加到已发布的记录中,因为 Kafka 日志是不可变的。为此,您可以使用包含未键入记录的主题中的数据,并在每条记录中设置一个密钥并将它们重新发布到另一个主题。

PARTITION BY 您可以使用以下语句使用 KSQL 完成此操作:

CREATE STREAM KEYED_STREAM as \
  SELECT * FROM UNKEYED_STREAM PARTITION BY <key column>;
于 2018-10-22T14:45:44.107 回答