Löschen des Statusspeichers der Anwendung

Question

Ich möchte den Statusspeicher einer bestimmten Instanz in einer Kafka-Stream-Anwendung löschen. Angenommen, ich führe die Höchstwerte der Liste in einem Zustand auf, möchte sie stündlich löschen. Gibt es einen Weg dies zu tun - ohne die Anwendung zu stoppen?

Answer 1

Scheint möglich.

Zum Beispiel können Sie einen Punctuation Zeitplan registrieren, der einmal eine auf der Wanduhr basierende Zeit auslöst, die alle Einträge aus dem Geschäft löscht.

https://docs.confluent.io/current/streams/developer-guide/processor-api.html#defining-a-stream-processor