View Source KafkaEx.Client.ResponseParser (kafka_ex v1.0.0-rc.1)

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

Summary

Functions

api_versions_response(response)

Parses response for ApiVersions API

create_topics_response(response)

Parses response for CreateTopics API

delete_topics_response(response)

Parses response for DeleteTopics API

describe_groups_response(response)

Parses response for Describe Groups API

fetch_response(response)

Parses response for Fetch API

find_coordinator_response(response)

Parses response for FindCoordinator API

heartbeat_response(response)

Parses response for Heartbeat API

join_group_response(response)

Parses response for JoinGroup API

leave_group_response(response)

Parses response for LeaveGroup API

list_offsets_response(response)

Parses response for List Groups API

metadata_response(response)

Parses response for Metadata API

offset_commit_response(response)

Parses response for Offset Commit API

offset_fetch_response(response)

Parses response for Offset Fetch API

produce_response(response)

Parses response for Produce API

sync_group_response(response)

Parses response for SyncGroup API

Functions

api_versions_response(response)

@spec api_versions_response(term()) ::
  {:ok, KafkaEx.Messages.ApiVersions.t()} | {:error, KafkaEx.Client.Error.t()}

Parses response for ApiVersions API

create_topics_response(response)

@spec create_topics_response(term()) ::
  {:ok, KafkaEx.Messages.CreateTopics.t()} | {:error, KafkaEx.Client.Error.t()}

Parses response for CreateTopics API

delete_topics_response(response)

@spec delete_topics_response(term()) ::
  {:ok, KafkaEx.Messages.DeleteTopics.t()} | {:error, KafkaEx.Client.Error.t()}

Parses response for DeleteTopics API

describe_groups_response(response)

@spec describe_groups_response(term()) ::
  {:ok, [KafkaEx.Messages.ConsumerGroupDescription.t()]} | {:error, term()}

Parses response for Describe Groups API

fetch_response(response)

@spec fetch_response(term()) ::
  {:ok, KafkaEx.Messages.Fetch.t()} | {:error, KafkaEx.Client.Error.t()}

Parses response for Fetch API

find_coordinator_response(response)

@spec find_coordinator_response(term()) ::
  {:ok, KafkaEx.Messages.FindCoordinator.t()}
  | {:error, KafkaEx.Client.Error.t()}

Parses response for FindCoordinator API

heartbeat_response(response)

@spec heartbeat_response(term()) ::
  {:ok, :no_error | KafkaEx.Messages.Heartbeat.t()}
  | {:error, KafkaEx.Client.Error.t()}

Parses response for Heartbeat API

join_group_response(response)

@spec join_group_response(term()) ::
  {:ok, KafkaEx.Messages.JoinGroup.t()} | {:error, KafkaEx.Client.Error.t()}

Parses response for JoinGroup API

leave_group_response(response)

@spec leave_group_response(term()) ::
  {:ok, :no_error | KafkaEx.Messages.LeaveGroup.t()}
  | {:error, KafkaEx.Client.Error.t()}

Parses response for LeaveGroup API

list_offsets_response(response)

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

Parses response for List Groups API

metadata_response(response)

@spec metadata_response(term()) ::
  {:ok, KafkaEx.Cluster.ClusterMetadata.t()}
  | {:error, KafkaEx.Client.Error.t()}

Parses response for Metadata API

offset_commit_response(response)

@spec offset_commit_response(term()) ::
  {:ok, [KafkaEx.Messages.Offset.t()]} | {:error, KafkaEx.Client.Error.t()}

Parses response for Offset Commit API

offset_fetch_response(response)

@spec offset_fetch_response(term()) ::
  {:ok, [KafkaEx.Messages.Offset.t()]} | {:error, KafkaEx.Client.Error.t()}

Parses response for Offset Fetch API

produce_response(response)

@spec produce_response(term()) ::
  {:ok, KafkaEx.Messages.RecordMetadata.t()}
  | {:error, KafkaEx.Client.Error.t()}

Parses response for Produce API

sync_group_response(response)

@spec sync_group_response(term()) ::
  {:ok, KafkaEx.Messages.SyncGroup.t()} | {:error, KafkaEx.Client.Error.t()}

Parses response for SyncGroup API