Skip to content

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

Description

@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

Metadata

Metadata

Assignees

No one assigned

    Labels

    questionFurther information is requested

    Type

    No type

    Fields

    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions