Broadway.Message.failed

You're seeing just the function failed, go back to Broadway.Message module for more information.

Specs

failed(message :: t(), reason :: binary()) :: t()

Mark a message as failed.

Failed messages are sent directly to the related acknowledger so they're not forwarded to the next step in the pipeline.