misha_cafex v0.0.6 Cafex.Protocol.OffsetCommit

This api saves out the consumer’s position in the stream for one or more partitions.

The offset commit 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(request)

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

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

decoder(request)

encode(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(request)

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

decode(data)

Specs

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

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

decoder(request)

encode(request)

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

has_response?(request)

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