Packages

elsa_fi

2.3.0
3.5.0 3.4.0 3.3.0 3.2.0 3.1.0 3.0.0 2.5.0 2.4.0 2.3.0 2.2.0 2.1.0 2.0.2 2.0.1 0.0.3 0.0.1 0.0.1-tagless

Elsa is a full-featured Kafka library written in Elixir and extending the :brod library with additional support from the :kafka_protocol Erlang libraries to provide capabilities not available in :brod. (Simpli.fi fork)

HexDocs

Current section

Files

Jump to
Readme
16 Versions
1 Dependency
Dependants
Files
Activity
elsa_fi lib elsa partitioner md5.ex
Raw

lib/elsa/partitioner/md5.ex 

defmodule Elsa.Partitioner.Md5 do

  @moduledoc """

  Chooses a topic partition based on an md5 hash of the

  supplied value, typically the message content.

  """



  @behaviour Elsa.Partitioner



  def partition(count, key) do

    :crypto.hash(:md5, key)

    |> :binary.bin_to_list()

    |> Enum.sum()

    |> rem(count)

  end

end