misha_cafex v0.0.5 Cafex.Partitioner behaviour

Partitioner implementation specification for Kafka produce request API.

Callbacks

• init(partitions)

• partition(message, state)

Summary

Types

state()

Callbacks

init(partitions)

partition(message, state)

Types

state :: term

Callbacks

init(partitions)

Specs

init(partitions :: integer) ::
  {:ok, state} |
  {:error, term}

partition(message, state)

Specs

partition(message :: Cafex.Protocol.Message.t, state) :: {integer, state}