View Source KafkaEx.LegacyPartitioner (kafka_ex v0.14.0)

Legacy default partitioner implementation.

This "legacy partitioner" used to be the default partitioner for KafkaEx when a message key is set and a partition isn't. This was intended to match the behaviour of the default Java client, however there was some small differences. This legacy partitioner keeps the previous behaviour, and the current default partitioner now correctly matches the Java client.

Summary

Functions

assign_partition(request, metadata)

Callback implementation for KafkaEx.Partitioner.assign_partition/2.

Functions

Link to this function

assign_partition(request, metadata)

View Source 
@spec assign_partition(
  request :: KafkaEx.Protocol.Produce.Request.t(),
  metadata :: KafkaEx.Protocol.Metadata.Response.t()
) :: KafkaEx.Protocol.Produce.Request.t()

Callback implementation for KafkaEx.Partitioner.assign_partition/2.