misha_cafex

defmodule Cafex.Partitioner.Hashed do
  @moduledoc """
  Hashed partitioner implementation.

  Read `Cafex.Partitioner` behaviour.
  """

  @behaviour Cafex.Partitioner

  def init(partitions) do
    {:ok, partitions}
  end

  def partition(message, partitions) do
    hash = :erlang.phash2(message.key, partitions)
    {hash, partitions}
  end
end