Elsa Kafka
v2.0.0

View Source Elsa.Partitioner behaviour (Elsa Kafka v2.0.0)

Behaviour for partitioning messages produced to Kafka.

Link to this section Summary

Types

partition()

Partition selected by the partitioning strategy.

partition_count()

The number of partitions for a topic.

Callbacks

partition(partition_count, key)

Link to this section Types

Link to this type

partition()

View Source 
@type partition() :: non_neg_integer()

Partition selected by the partitioning strategy.

Link to this type

partition_count()

View Source 
@type partition_count() :: pos_integer()

The number of partitions for a topic.

Link to this section Callbacks

Link to this callback

partition(partition_count, key)

View Source 
@callback partition(partition_count(), key :: term()) :: partition()