View Source KafkaEx.Protocol.Kayrock.Metadata.RequestHelpers (kafka_ex v1.0.0-rc.1)

Helper functions for building Metadata requests across different protocol versions.

Summary

Functions

Checks if auto topic creation should be enabled.

Extracts and normalizes topics list from options.

Builds a V8+ Metadata request with authorized operations fields.

Returns the default API version for Metadata requests.

Functions

Link to this function

allow_auto_topic_creation?(opts)

View Source
@spec allow_auto_topic_creation?(Keyword.t()) :: boolean()

Checks if auto topic creation should be enabled.

@spec build_topics_list(Keyword.t()) :: [%{name: String.t()}] | nil

Extracts and normalizes topics list from options.

Wraps plain string topics as %{name: topic} maps, which is the format Kayrock's serializer expects for all Metadata API versions.

Link to this function

build_v8_plus_request(request_template, opts)

View Source
@spec build_v8_plus_request(map(), Keyword.t()) :: map()

Builds a V8+ Metadata request with authorized operations fields.

V8 adds include_cluster_authorized_operations and include_topic_authorized_operations. V9 uses the same fields with compact encoding (handled by Kayrock).

@spec default_api_version() :: 0 | 1 | 2

Returns the default API version for Metadata requests.