View Source KafkaEx.Protocol.Kayrock.JoinGroup.Request protocol (kafka_ex v1.0.0-rc.1)

This protocol is used to build JoinGroup requests.

V0 Options

  • group_id (required): The consumer group ID
  • session_timeout (required): Session timeout in milliseconds
  • member_id (required): The member ID (empty string for new members)
  • group_protocols or topics (required): Group protocols or topics list
  • protocol_type (optional): Protocol type, defaults to "consumer"

V1-V4 Options (adds to V0)

  • rebalance_timeout (required): Rebalance timeout in milliseconds

V5-V6 Options (adds to V1-V4)

  • group_instance_id (optional): Static membership instance ID (nil for dynamic)

All known versions (V0-V6) have explicit implementations. The Any fallback handles unknown future versions.

Summary

Types

t()

All the types that implement this protocol.

Types

@type t() :: term()

All the types that implement this protocol.

Functions

Link to this function

build_request(request, opts)

View Source
@spec build_request(t(), Keyword.t()) :: t()