apache-kafka - 如果我在主题级别和生产者级别设置 'compression.type'，则优先

Question

我试图了解“compression.type”配置，我的问题是，
如果我在主题级别和生产者级别设置“compression.type”，哪个优先？

Answer 1

当代理收到来自生产者的一批压缩消息时:

它总是解压数据以验证它

它考虑目标主题的压缩编解码器

如果目标主题的压缩编解码器是 producer ，或者如果批处理和目标主题的编解码器相同，则代理从客户端获取压缩的批处理并将其直接写入主题的日志文件，而无需重新压缩数据。

否则，代理需要重新压缩数据以匹配目标主题的编解码器。

如果生产者运行 0.10 之前的版本，因为需要覆盖偏移量，或者需要任何其他消息格式转换，也可能会发生解压缩和重新压缩。