karafka/karafka

Method on_error_occurred has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

          def on_error_occurred(event)
            push_tags

            error = event[:error]
            client.active_span&.set_error(error)