View Source KafkaEx.New.Structs.NodeSelector (kafka_ex v0.14.0)

@type t() :: %KafkaEx.New.Structs.NodeSelector{
  consumer_group_name: KafkaEx.New.KafkaExAPI.consumer_group_name() | nil,
  node_id: non_neg_integer() | nil,
  partition: KafkaEx.New.KafkaExAPI.partition_id() | nil,
  strategy: valid_strategy(),
  topic: KafkaEx.New.KafkaExAPI.topic_name() | nil
}

valid_strategy()

@type valid_strategy() ::
  :node_id
  | :random
  | :first_available
  | :controller
  | :topic_partition
  | :consumer_group

Functions

consumer_group(consumer_group_name)

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

Select the controller for the given consumer group

controller()

@spec controller() :: t()

Select the cluster's controller node

first_available()

@spec first_available() :: t()

Select first available node

node_id(node_id)

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

Select a specific node

random()

@spec random() :: t()

Select a random node

topic_partition(topic, partition)

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

Select the controller for the given topic and partition