View Source KafkaEx.New.Client.Protocol behaviour (kafka_ex v0.14.0)

This module is responsible for defining the behaviour of a protocol.

Summary

api_version()

consumer_group()

params()

@type api_version() :: non_neg_integer()

@type consumer_group() :: KafkaEx.New.Structs.ConsumerGroup

@type params() :: Keyword.t()

@callback build_request(:describe_groups, integer(), params()) :: term()

@callback parse_response(:describe_groups, term()) ::
  {:ok, [consumer_group()]} | {:error, term()}