apache kafka сохранение kstream и связанная тема - PullRequest
0 голосов
/ 14 ноября 2018

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

1 Ответ

0 голосов
/ 14 ноября 2018

Темы журнала изменений сжаты в журнале с бесконечным временем хранения. В любое время, если в вашей теме появится новое событие, оно обновит состояние в таблицах KTable для этого ключа.

В вашем сценарии, если вам нужно сделать данные доступными даже после удаления исходного раздела, я рекомендую опубликовать KTable в некотором выходном разделе, чтобы сделать его более стабильным.
Поскольку таблицы KTable доступны только в приложениях и основаны на темах журнала изменений, после того как ваше приложение исчезнет, ​​вы потеряете данные, если не будете использовать постоянное хранилище состояний.

...