How do i listen to streams state using a topology provider ?

[Dharin-shah]

Search for existing answers
Many questions have been asked before. Please have a quick search to see if there is already an answer to your question. There are two main resources for finding answers:

1. Existing Azkarra Github issues, including closed issues
2. Azkarra Slack Channel

If you can't see an answer to your question, then please raise a new Github or Stack overflow issue.

Provide details of the setup you're running
Let us know what version of Azkarra you're running, what OS, Docker version etc,
Azkarra version - implementation('io.streamthoughts:azkarra-streams:0.9.2')
Java 17

Outline your question
Ask you question!
I want to listen to kafka state, i.e. whenever the application restarts or shuts down, i want to listen to that event, and take an action (essentially clean up the in-memory state stores) since i run on a stateless environment with ephemeral storage