现在我正在用apachekafka做一些测试。在kafka producer的配置中，参数batch.size和linger.ms控制批处理策略。有没有可能在生产过程中动态生成这些参数？e、 g.如果数据摄取率快速上升，我们可能需要增加batch.size，以便每批累积更多的消息。我没有找到任何与Kafka生产者动态批处理的例子。是否可以实施？
kx5bkwkv1#
这是可能的，但是您必须在运行时使用更新的配置关闭并重新打开一个新的producer示例，同时确保不会在该操作之间删除事件。
1条答案
按热度按时间kx5bkwkv1#
这是可能的，但是您必须在运行时使用更新的配置关闭并重新打开一个新的producer示例，同时确保不会在该操作之间删除事件。