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
Checks if auto topic creation should be enabled.
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.
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.