Skip to content

Handle kafka errors following kafka best practices

Fabfur requested to merge retry-kafka-errors into main

This MR includes the following changes:

  • Stop requiring Fatal() from KafkaReader.Read() to signal a fatal error to the caller
  • Fix KafkaReader tests
  • Stop KafkaReader.Read() execution only if ErrAllBrokersDown is received, log all the other errors

Bug: T354712 Bug: T334078

Edited by Vgutierrez

Merge request reports