kafka_ex v0.12.1-42-6

KafkaEx.TtPartitioner (kafka_ex v0.12.1-42-6) View Source

Tt partitioner implementation.

This partitioner differs from the default one by selecting partition_id only from the topic partitions with no_error.

Link to this section Summary

Functions

assign_partition(request, metadata)

Callback implementation for KafkaEx.Partitioner.assign_partition/2.

Link to this section Functions

Link to this function

assign_partition(request, metadata)

View Source

Specs

assign_partition(
  request :: %KafkaEx.Protocol.Produce.Request{
    api_version: term(),
    compression: term(),
    messages: term(),
    partition: term(),
    required_acks: term(),
    timeout: term(),
    topic: term()
  },
  metadata :: %KafkaEx.Protocol.Metadata.Response{
    brokers: term(),
    controller_id: term(),
    topic_metadatas: term()
  }
) :: %KafkaEx.Protocol.Produce.Request{
  api_version: term(),
  compression: term(),
  messages: term(),
  partition: term(),
  required_acks: term(),
  timeout: term(),
  topic: term()
}

Callback implementation for KafkaEx.Partitioner.assign_partition/2.