Kayrock.MemberAssignment (kayrock v1.0.1)

Copy Markdown 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

Summary

Types

t()

Functions

deserialize(arg)
deserialize_content(data)
serialize(member_assignment)

Types

t()

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

Functions

deserialize(arg)

@spec deserialize(binary()) :: {t(), binary()}

deserialize_content(data)

@spec deserialize_content(binary()) :: t() | no_return()

serialize(member_assignment)

@spec serialize(t()) :: iodata()