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

This module is used to build request for KafkaEx.New.Client. It's main decision point which protocol to use for building request and what is required version.

Summary

Functions

describe_groups_request(request_opts, state)

Builds request for Describe Groups API

lists_offset_request(request_opts, state)

Builds request for List Offsets API

Functions

Link to this function

describe_groups_request(request_opts, state)

View Source 
@spec describe_groups_request(Keyword.t(), KafkaEx.New.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for Describe Groups API

Link to this function

lists_offset_request(request_opts, state)

View Source 
@spec lists_offset_request(Keyword.t(), KafkaEx.New.Client.State.t()) ::
  {:ok, term()} | {:error, :api_version_no_supported}

Builds request for List Offsets API