Управление прослушивателем Kafka Consumer - PullRequest
1 голос
/ 11 мая 2019

Предположим, что потребитель Kafka должен потреблять 5 сообщений, и они будут обработаны в классе A и классе B.

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

Мой вопрос: все ли 5 ​​сообщений будут использованы немедленно (одно за другим) или есть какой-то период времени, чтобы использовать одну информацию после следующего сообщения. Причина этого вопроса в том, что сообщение 1 используется в вышеуказанном потоке, а класс PROCESS B занимает больше времени. Будет ли Сообщение 2 использовано до завершения класса PROCESS B для Сообщения 1.

...