Управление прослушивателем Kafka Consumer
Предположим, что потребитель Kafka должен потреблять 5 сообщений, и они будут обработаны в классах A и B.
5 Messages --> KAFKA CONSUMER --> PROCESS A CLASS ---> PROCESS B Class
Мой вопрос: все ли 5 сообщений будут использованы немедленно (одно за другим) или есть какой-то период времени, чтобы использовать одну информацию после следующего сообщения. Причина этого вопроса в том, что сообщение 1 используется в вышеуказанном потоке, а класс PROCESS B занимает больше времени. Будет ли Сообщение 2 использоваться до завершения класса PROCESS B для Сообщения 1.