Packages

kafka_ex

0.6.2
1.1.1 1.1.0 1.0.2 1.0.1 1.0.0 1.0.0-rc.3 1.0.0-rc.2 1.0.0-rc.1 0.15.0 0.15.0-dev.1 0.14.0 0.14.0-rc.1 0.13.0 0.12.1 0.11.0 0.10.0 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.0 0.6.5 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.0 0.0.2 0.0.1

Elixir client for Apache Kafka with automatic API version negotiation, SASL authentication (PLAIN, SCRAM, OAuth, MSK IAM), consumer groups, compression, and telemetry support.

HexDocs

Current section

Files

Jump to
Readme
36 Versions
0 Dependencies
Dependants
Files
Activity
kafka_ex lib kafka_ex protocol heartbeat.ex
Raw

lib/kafka_ex/protocol/heartbeat.ex 

defmodule KafkaEx.Protocol.Heartbeat do

  @moduledoc """

  Implementation of the Kafka Hearbeat request and response APIs

  """



  defmodule Response do

    @moduledoc false

    # We could just return the error code instead of having the struct, but this

    # keeps the code normalized

    defstruct error_code: nil

    @type t :: %Response{error_code: atom | integer}

  end



  @spec create_request(integer, binary, binary, binary, integer) :: binary

  def create_request(correlation_id, client_id, member_id, group_id, generation_id) do

    KafkaEx.Protocol.create_request(:heartbeat, correlation_id, client_id) <>

      << byte_size(group_id) :: 16-signed, group_id :: binary,

         generation_id :: 32-signed,

         byte_size(member_id) :: 16-signed, member_id :: binary >>

  end



  @spec parse_response(binary) :: Response.t

  def parse_response(<< _correlation_id :: 32-signed, error_code :: 16-signed >>) do

    %Response{error_code: KafkaEx.Protocol.error(error_code)}

  end



end