apache-kafka - 控制 Kafka Consumer 监听器

Question

假设 Kafka 消费者必须消费 5 条消息，这些消息将在 A 类和 B 类中处理。

5 Messages --> KAFKA CONSUMER --> PROCESS A CLASS ---> PROCESS B Class

我的问题是：所有 5 条消息是否会立即（一条一条地）被消费，或者是否有任何时间段在下一条消息之后消费一条数据。这个问题的原因是如果消息 1 在上述流程中被消费并且 PROCESS B 类需要更长的时间。消息 2 是否会在消息 1 的 PROCESS B 类完成之前被使用。

标签： apache-kafkaapache-camellistenerconsumercontrolling