Skip to content

feat(runtime): add new StreamThreadExceptionHandler to restart new StreamThread. #149

@fhussonnois

Description

@fhussonnois

Describe the solution you'd like
Kafka Streams 2.8 adds a new API for starting or stopping Streams threads to scale or to recover from failures. Azkarra should now provides a new StreamThreadExceptionHandler that start a new StreamThread when an exception happens.

Metadata

Metadata

Assignees

No one assigned

    Labels

    in:runtimeThis issue should impact the azkarra-runtime modulejavaPull requests that update Java codetype:enhancementNew feature or request

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions