Packages

kafka_ex

0.8.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 leave_group.ex
Raw

lib/kafka_ex/protocol/leave_group.ex 

defmodule KafkaEx.Protocol.LeaveGroup do

  defmodule Request do

    @moduledoc false

    defstruct group_name: nil, member_id: nil



    @type t :: %Request{

      group_name: binary,

      member_id: binary,

    }

  end



  defmodule Response do

    @moduledoc false



    defstruct error_code: nil



    @type t :: %Response{

      error_code: atom | integer,

    }

  end



  @spec create_request(integer, binary, Request.t) :: binary

  def create_request(correlation_id, client_id, request) do

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

      << byte_size(request.group_name) :: 16-signed, request.group_name :: binary,

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

  end



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

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

  end

end