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

This module handles CreateTopics request & response parsing. Request is built using Kayrock protocol, response is parsed to native KafkaEx structs.

Supported Versions

• V0: Basic topic creation
• V1: Adds validate_only flag and error_message in response
• V2: Adds throttle_time_ms in response
• V3: Pure version bump (identical to V2)
• V4: Pure version bump (identical to V3)
• V5: Flexible version (KIP-482). Response adds num_partitions, replication_factor, configs per topic