Как изменить или добавить ключ темы в Kafka или KSQL

Question

У меня есть много тем, созданных без ключа, как я могу изменить их и добавить нужную?

Мне нужно изменить это для некоторых соединителей, которые хотят, чтобы они правильно читали тему

Я лично использую ksql, но я не нашел способа сделать это

Answer 1

Ключи добавляются в записи, а не в темы.Вы можете просто начать писать свои записи с ключами.

Невозможно добавить ключи к уже опубликованным записям, поскольку журналы Kafka неизменны.Для этого вы можете использовать данные из темы, содержащей записи без ключей, установить ключ в каждой записи и повторно опубликовать их в другой теме.

Это можно сделать с помощью KSQL, используя оператор PARTITION BY :

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