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

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

Supported Versions

• V0: Basic produce (MessageSet format)
• V1: Same as V0, clarified acks semantics
• V2: Adds timestamp support in MessageSet, adds log_append_time in response
• V3: Adds transactional_id, uses RecordBatch format with headers
• V4: Same as V3, transactional/idempotent producer support
• V5: Response adds log_start_offset
• V6: No changes vs V5
• V7: No changes vs V6
• V8: Response adds record_errors and error_message per partition (KIP-467)

Message Format Differences

• V0-V2: Uses Kayrock.MessageSet with individual messages
• V3+: Uses Kayrock.RecordBatch with records and headers support

All known versions (V0-V8) have explicit defimpl implementations. An Any fallback is retained for forward compatibility with unknown future Kayrock versions.