1

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

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

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

4

0 回答 0