Kafka broker是为每条消息还是为每批消息发送ACK？
我用的是Kafka0.8.2。正如文件所说：
batch.num.messages指定：
使用异步模式时要在一批中发送的消息数。生产者将等待该数量的消息准备好发送或排队。缓冲器已达到最大毫秒。
和请求。必修的。acks控制代理对请求的确认。
我想知道Kafka经纪人如何发送这个确认，它是否发送批次确认字符，还是每个单独的消息？
共有1个答案
http://www.slideshare.net/miguno/apache-kafka-08-basic-training-verisign（幻灯片83）：
根据消息的目标分区/主题对原始消息列表进行分区（如果使用默认分区器，则会随机进行），即分成更小的批。每个拆分后的批处理都被发送到各自的leader broker/ISR（单独的send（）按顺序进行），每个批处理都由各自的leader broker根据请求进行确认。必修的。阿克斯
-
我们有一个Spring Boot应用程序，用于在另一个组件上执行负载测试。我们每分钟最多需要发送35000条JMS消息，因此我使用调度器每分钟运行一次任务。 问题是当我保持低强度时，它会设法在指定的时间间隔（一分钟）内发送消息。但是当强度很高时，发送消息块需要超过1分钟。对以下实现有任何建议吗？ 调度程序类 用于发送消息的类
-
我正在尝试用redis streams实现一个java应用程序，其中每个consomer只使用一条消息。就像管道/队列一样，每个使用者只接收一条消息，对其进行处理，完成后，使用者接收流中尚未处理的下一条消息。有效的方法是，每条消息只被一个消费者（使用xreadgroup）使用。 我从redislabs开始学习本教程 守则： 我当前的问题是，一个消费者从队列中获取多条消息，在某些情况下，其他消费者正
-
我试图在不和谐的情况下每隔x秒发送一条消息。js机器人。我知道如何做到这一点，但我遇到的问题是，即使我启用了slowmode，它也会发送垃圾邮件。我怎样才能解决这个问题？
-
保存/记录在AWS SNS主题上发布的每条消息的最简单方法是什么？我想可能有一个神奇的设置可以自动将它们推送到S3或数据库，或者可能是一个自动支持HTTP目标的数据库服务，但似乎并非如此。也许需要通过Lambda函数来完成？ 目的只是为了在设置一些SNS发布时进行基本的诊断和调试。我并不真正关心大规模或快速查询，只想一次记录和执行几分钟对所有活动的基本查询。
-
我过去使用过Kafka，但从未使用过streams API。我的任务是构建一个可扩展的服务，该服务接受websocket连接，并根据用户id将出站消息从中心主题路由到正确的会话。 使用KStream看起来非常简单 但是筛选器命令是否消耗了主题中的每一条消息并在应用程序空间中执行筛选器？或者KStream KStream上的措辞 如果过滤器的唯一目的是使用某个主题的每一条消息，并扔掉那些不相关的消息
-
20.3. 发送一条消息 JmsTemplate包含许多方便的方法来发送消息。有些发送方法可以使用 javax.jms.Destination对象指定目的地，也可以使用字符串在JNDI中查找目的地。没有目的地参数的发送方法使用默认的目的地。这里有个例子使用1.0.2版的JMS实现发送消息到一个队列。 import javax.jms.ConnectionFactory; import javax.