kayrock v0.1.12

Kayrock.MemberAssignment (kayrock v0.1.12) View Source

Code to serialize/deserialize Kafka consumer group member assignments

See https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-SyncGroupRequest

Link to this section Summary

Types

t()

Functions

deserialize(arg)
serialize(member_assignment)

Link to this section Types

Link to this type

t()

View Source

Specs

t() :: %Kayrock.MemberAssignment{
  partition_assignments: [Kayrock.MemberAssignment.PartitionAssignment.t()],
  user_data: binary(),
  version: integer()
}

Link to this section Functions

Link to this function

deserialize(arg)

View Source

Specs

deserialize(binary()) :: {t(), binary()}
Link to this function

serialize(member_assignment)

View Source

Specs

serialize(t()) :: iodata()