Как усечь KTable

Question

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

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

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

Спасибо

Answer 1

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

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

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