misha_cafex v0.0.5 Cafex.Protocol.OffsetCommit.Request

Summary

Types

api_version :: 0 | 1 | 2
partition_v0 :: {partition :: integer, offset :: integer, metadata :: binary}
partition_v1 :: {partition :: integer, offset :: integer, timestamp :: integer, metadata :: binary}
partition_v2 :: {partition :: integer, offset :: integer, metadata :: binary}
t :: %Cafex.Protocol.OffsetCommit.Request{api_version: api_version, consumer_group: String.t, consumer_group_generation_id: integer | nil, consumer_id: String.t | nil, retention_time: integer | nil, topics: [topic]}
topic :: {topic_name :: String.t, partitions :: [partition]}