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

Defines node selector functions and macros

Link to this section Summary

Types

t()

Functions

consumer_group(consumer_group_name)

Select the controller for the given consumer group

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

topic_partition(topic, partition)

Select the controller for the given topic and partition

Link to this section Types

t()

Specs

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

Link to this section Functions

consumer_group(consumer_group_name)

Specs

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

Select the controller for the given consumer group

controller()

Specs

controller() :: t()

Select the cluster's controller node

first_available()

Specs

first_available() :: t()

Select first available node

node_id(node_id)

Specs

node_id(KafkaEx.New.KafkaExAPI.node_id()) :: t()

Select a specific node

random()

Specs

random() :: t()

Select a random node

topic_partition(topic, partition)

Specs

topic_partition(
  KafkaEx.New.KafkaExAPI.topic_name(),
  KafkaEx.New.KafkaExAPI.partition_id()
) :: t()

Select the controller for the given topic and partition