basic_broadway.exs

defmodule MyBroadway do
  use Broadway

  alias Broadway.Message

  def start_link(_opts) do
    Broadway.start_link(__MODULE__,
      name: __MODULE__,
      producer: [
        # producer configuration
      ],
      processors: [
        # processor configuration
      ],
      batchers: [
        # batchers configuration
      ]
    )
  end

  def handle_message(_processor_name, message, _context) do
    ....
  end

  def handle_batch(_batch, messages, _batch_info, _context) do
    .....
  end
end