View Source KafkaEx.Messages.SyncGroup (kafka_ex v1.0.0-rc.1)

This module represents SyncGroup response from Kafka.

The response includes partition assignments for the consumer group member.

Summary

Types

t()

Functions

build(opts \\ [])

Builds a SyncGroup struct from response data.

Types

t()

@type t() :: %KafkaEx.Messages.SyncGroup{
  partition_assignments: [
    KafkaEx.Messages.ConsumerGroupDescription.Member.MemberAssignment.PartitionAssignment.t()
  ],
  throttle_time_ms: nil | non_neg_integer()
}

Functions

build(opts \\ [])

@spec build(Keyword.t()) :: t()

Builds a SyncGroup struct from response data.