ksqlDB - 如何为生产者设置 batch.size 和 linger.ms 以优化压缩

【问题标题】：ksqlDB - How to set batch.size and linger.ms for producers to optimise compressionksqlDB - 如何为生产者设置 batch.size 和 linger.ms 以优化压缩
【发布时间】：2025-11-25 15:35:01
【问题描述】：

在配置 ksqlDB 时，我可以设置选项 ksql.streams.producer.compression.type，它为 ksqlDB 的内部生产者启用压缩。因此，当我创建一个 ksqlDB 流时，它的输出主题将使用选定的压缩类型进行压缩。

但是，据我了解，压缩性能在很大程度上受到生产者批处理的影响。因此，我希望能够为 ksqlDB 的生产者配置batch.size 和linger.ms 参数。有谁知道是否可以为 ksqlDB 设置这些参数以及如何设置这些参数？

【问题讨论】：

标签： apache-kafka apache-kafka-streams confluent-platform ksqldb

【解决方案1】：

感谢 Matthias J Sax 在 Confluent Community Slack 频道上回答我的问题：https://app.slack.com/client/T47H7EWH0/threads?cdn_fallback=1

文档中有一个信息框。这很好地解释了它：

KSQL documentation info box

ksqlDB 的服务器中的底层生产者和消费者客户端可以是使用任何有效属性进行修改。只需使用表格 ksql.streams.producer.xxx、ksql.streams.consumer.xxx 传递财产通过。例如，ksql.streams.producer.compression.type 设置生产者的压缩类型。

来源：https://docs.ksqldb.io/en/latest/reference/server-configuration/

【讨论】：