Count Strategy

Stores the offset after every store_after messages.

Usage

defmodule MyApp.MyConsumer do
  alias RabbitMQStream.Consumer.OffsetTracking

  use RabbitMQStream.Consumer,
    offset_tracking: [OffsetTracking.CountStrategy, store_after: 50]

  @impl true
  def handle_message(_message) do
    :ok
  end
end

Parameters

• store_after - the number of messages to receive before storing the offset