@dongjinleekr Yes, exactly. I think we can modify `RecordsUtil.downConvert` to raise `UnsupportedCompressionTypeException`. Then we need to catch the exception in two places: 1. Inside `KafkaApis.maybeConvertFetchedData` when we construct the `LazyDownConversionRecords` instance. Here we can set the correct error code in the response. 2. Inside `LazyDownConversionRecordsSend` when we advance the iterator. Here we can return the overflow batch.
[ Full content available at: https://github.com/apache/kafka/pull/2267 ] This message was relayed via gitbox.apache.org for [email protected]
