broker() :: {host :: String.t(), port :: pos_integer()}

sasl_config() :: {:plain, username :: String.t(), password :: String.t()}

ssl_config() :: %{
  path_to_key_pem: String.t(),
  key_password: String.t(),
  path_to_cert_pem: String.t(),
  path_to_ca_cert_pem: String.t()
}

t() :: %{
  brokers: [broker()],
  consumer_topics: [topic()],
  server_id: atom(),
  client_id: atom(),
  group_id: String.t(),
  ssl: nil | ssl_config(),
  sasl: nil | sasl_config()
}

topic() :: String.t()