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

Encapsulates what we know about a broker and our connection

Summary

Types

t()

Functions

has_socket?(arg1, socket)

Types

t()

@type t() :: %KafkaEx.New.Structs.Broker{
  host: binary(),
  node_id: non_neg_integer(),
  port: non_neg_integer(),
  rack: binary(),
  socket: KafkaEx.Socket.t() | nil
}

Functions

has_socket?(arg1, socket)