So, the strategy you are proposing is ... 1. If the record batches which down conversion is requested start with ZSTD compressed batches, return a UNSUPPORTED_COMPRESSION_TYPE error. 2. If there ZSTD compressed batches are in the middle of the batches, takes fallback to case 1 by returning normal batches with overflow records.
Am I right? As far as I understand, this strategy looks perfectly reasonable to me. If you add some update, I will update the downconversion logic part in KIP document appropriately ASAP. Thanks in advance! [ Full content available at: https://github.com/apache/kafka/pull/2267 ] This message was relayed via gitbox.apache.org for [email protected]
