Packages

kafe

2.1.3
2.2.3 2.2.1 2.2.0 2.1.7 2.1.6 2.1.5 2.1.4 2.1.3 2.1.2 2.1.1 2.1.0 2.0.0 1.6.2 1.6.1 1.6.0 1.5.1 1.5.0

A Kafka client for Erlang and Elixir

Current section

Files

Jump to
Readme
17 Versions
6 Dependencies
Dependants
Files
Activity
kafe src kafe_protocol_group_coordinator.erl
Raw

src/kafe_protocol_group_coordinator.erl 

% @hidden

-module(kafe_protocol_group_coordinator).



-include("../include/kafe.hrl").



-export([

         run/1,

         request/2,

         response/2

        ]).



run(ConsumerGroup) ->

  kafe_protocol:run({call,

                     fun ?MODULE:request/2, [ConsumerGroup],

                     fun ?MODULE:response/2}).



request(ConsumerGroup, State) ->

  kafe_protocol:request(

    ?GROUP_COORDINATOR_REQUEST,

    <<(kafe_protocol:encode_string(ConsumerGroup))/binary>>,

    State,

    ?V0).



response(<<ErrorCode:16/signed,

           CoordinatorID:32/signed,

           CoordinatorHostLength:16/signed,

           CoordinatorHost:CoordinatorHostLength/bytes,

           CoordinatorPort:32/signed>>, _ApiVersion) ->

  {ok, #{error_code => kafe_error:code(ErrorCode),

         coordinator_id => CoordinatorID,

         coordinator_host => CoordinatorHost,

         coordinator_port => CoordinatorPort}}.