View Source KafkaEx.New.Client.ResponseParser (kafka_ex v0.15.0)

This module is used to parse response from KafkaEx.New.Client. It's main decision point which protocol to use for parsing response

Summary

Parses response for Describe Groups API

Parses response for List Groups API

@spec describe_groups_response(term()) ::
  {:ok, [KafkaEx.New.Structs.ConsumerGroup.t()]} | {:error, term()}

Parses response for Describe Groups API

@spec list_offsets_response(term()) ::
  {:ok, [KafkaEx.New.Structs.Offset.t()]}
  | {:error, KafkaEx.New.Structs.Error.t()}

Parses response for List Groups API