Как усечь KTable - PullRequest
Новая
       19

Как усечь KTable

0 голосов
/ 09 октября 2018

У меня есть потоковое приложение kafka, которое использует KTable.Мое приложение работало некоторое время, поэтому KTable уже создан.

Как обрезать KTable (при условии, что мое приложение может обработать восстановление таблицы)?

Останавливает мое приложение и также удаляет егоданные из топика изменений верны?Это кажется немного сложным, я чувствую, что должен быть более простой способ.

Спасибо

1 Ответ

0 голосов
/ 09 октября 2018

Если вы хотите заново создать KTable с нуля, вы можете использовать инструмент сброса приложения.Это может быть один вариант для вас.

Инструмент сброса приложения удалит все разделы журнала изменений и перераспределения, созданные для идентификатора приложения, и, следовательно, для нового запуска вы получите новый KTable и хранилище состояний.

https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Application+Reset+Tool

...