Packages

Cafex is a pure Elixir implementation of Kafka client.

Current section

Files

Jump to
misha_cafex lib cafex protocol leave_group.ex
Raw

lib/cafex/protocol/leave_group.ex

defmodule Cafex.Protocol.LeaveGroup do
use Cafex.Protocol, api: :leave_group
defrequest do
field :group_id, binary
field :member_id, binary
end
defresponse do
field :error, Cafex.Protocol.error
end
def encode(%{group_id: group_id, member_id: member_id}) do
[encode_string(group_id),
encode_string(member_id)]
|> IO.iodata_to_binary
end
def decode(<< error_code :: 16-signed >>) do
%Response{error: decode_error(error_code)}
end
end