zalando / nakadi

A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues

https://nakadi.io

MIT License

952 stars 293 forks source link

Workaround: reset subscriptions' running sessions on attaching DLQ pa… #1579

Closed 1u0 closed 7 months ago

1u0 commented 7 months ago

One-line summary

Description

This change resets (stops) subscription's running sessions upon attaching to the subscription the DLQ partitions. This would force a consuming application to re-connect to subscription (create new sessions) where they would be able to observe (consume) partitions of DLQ into addition to partitions from normal event types.

Note: this is a workaround (quick) solution. A better approach would be to rebalance partitions among running session without stopping them.

adyach commented 7 months ago

👍

1u0 commented 7 months ago

:+1: