为什么当我用AutoFlush将自定义值设置为False时，Async Producer不等待linger.ms或Batch.Size填满它们？ [英] Why async producer is not waiting for either linger.ms or batch.size to be full when i set them a custom value with autoFlush is set to false?

问题描述

我使用的是Spring-Kafka 2.2.8，并编写了一个简单的异步生成器，设置如下：

linger.ms : 300000, 
batch.size: 33554431, 
max.block.ms: 60000.

现在我正在通过调用下面的构造函数创建一个KafkaTemplate，并将AutoFlush设置为FALSE

public KafkaTemplate(ProducerFactory<K, V> producerFactory, boolean autoFlush) 

现在，我已经使用上面的异步生成器在10秒内生成了10条消息，然后使用‘CNTRL+C’停止了我的生成器。然后令人惊讶的是，我得到了发布在主题上的所有10条消息，我确定这10条消息的总和比我的批次要小得多。大小：33554431

现在我有两个问题

1. 如何发布邮件，而不是在生成邮件之前等待linger.ms或Batch.Size？
2. 在此方案中，AutoFlush=False有什么意义？

推荐答案

如果这是一个Spring Boot应用程序，Ctrl-C将关闭应用程序上下文，DefaultKafkaProducerFactory将关闭destroy()方法中的生成器(在close()期间由应用程序上下文调用)。

只有当您kill -9该应用程序时，您才会丢失记录。

这篇关于为什么当我用AutoFlush将自定义值设置为False时，Async Producer不等待linger.ms或Batch.Size填满它们？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！