Skip to content

Refactor kafka error retry logic

Fabfur requested to merge work/fabfur/refactor-getevents into main

Unrecoverable errors (kafka.Error.IsFatal()) now causes immediate process exit, without reaching an error count limit.

Recoverable errors are considerable retriable after a configurable amount of time (milliseconds).

Commented also Debug logging at each (successfully) sent message, left as placeholder to test zerolog.

Merge request reports