misha_cafex v0.0.5 Cafex.Protocol.OffsetFetch

This api reads back a consumer position previously written using the OffsetCommit api.

The offset fetch request support version 0, 1 and 2. To read more details, visit the A Guide to The Kafka Protocol.

Summary

Functions

api_key(request)

Callback implementation for Cafex.Protocol.Codec.api_key/1

api_version(arg1)

Callback implementation for Cafex.Protocol.Codec.api_version/1

Callback implementation for Cafex.Protocol.Codec.decode/1

decoder(request)

Callback implementation for Cafex.Protocol.Codec.encode/1

has_response?(request)

Callback implementation for Cafex.Protocol.Codec.has_response?/1

Functions

api_key(request)

Callback implementation for Cafex.Protocol.Codec.api_key/1.

api_version(arg1)

Callback implementation for Cafex.Protocol.Codec.api_version/1.

decode(data)

Specs

decode(binary) :: Cafex.Protocol.OffsetFetch.Response.t

Callback implementation for Cafex.Protocol.Codec.decode/1.

decoder(request)

encode(map)

Callback implementation for Cafex.Protocol.Codec.encode/1.

has_response?(request)

Callback implementation for Cafex.Protocol.Codec.has_response?/1.