stoewer/go-nakadi

Open a new stream when a processor stream was closed due o failing cursor commit

Closed this issue · 1 comments

The processor must open a new stream after the current stream was closed after failing to commit a cursor.

The current behavior will cause an infinite loop where the processor will not consume further events.

Hi .
Is there any progress for this issue ?