elsa

v0.12.3

elsa v0.12.3 Elsa.Producer.Partitioner

Provides functions for automatically selecting the topic partition to write a message.

Link to this section Summary

Functions

partition(atom, partition_count, key)

Choose a topic partition based on an md5 hash of the supplied value, typically the message content.

Link to this section Functions

Link to this function

partition(atom, partition_count, key)

partition(:default, integer(), term()) :: integer()
partition(:random, integer(), term()) :: integer()
partition(:md5, integer(), term()) :: integer()

Choose a topic partition based on an md5 hash of the supplied value, typically the message content.