时间戳

首页 > 解决方案 > ksqlDB - 如何为生产者设置 batch.size 和 linger.ms 以优化压缩

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

问题描述

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

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

标签： apache-kafkaapache-kafka-streamsconfluent-platformksqldb

解决方案

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

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

KSQL 文档信息框

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

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

推荐阅读