View Source KafkaEx.New.NodeSelector (kafka_ex v0.13.0)

Defines node selector functions and macros

Link to this section Summary

t()

Select the controller for the given consumer group

controller()

Select the cluster's controller node

first_available()

Select first available node

node_id(node_id)

Select a specific node

random()

Select a random node

Select the controller for the given topic and partition

@type t() :: %KafkaEx.New.NodeSelector{
  consumer_group_name: term(),
  node_id: term(),
  partition: term(),
  strategy: term(),
  topic: term()
}

@spec consumer_group(KafkaEx.New.KafkaExAPI.consumer_group_name()) :: t()