Конфигурация задания потока Kafka и Kafka:
Нет раздела: 40
Нет задачи потока: 40
Нет потока потока: 40
Семантика: ровно один раз.
Версия клиента Kafka: 2.3.0
Каждая задача будет сопоставлена с соответствующим одним разделом. И каждый поток потока будет выполнять одну задачу.
Когда Kafka Consumer опрашивает записи в пакетах от брокера. Допустим, потребительский клиент выбрал 10 записей, в которых было 5 записей из раздела № 38, и этот раздел был назначен задаче № 38.
Теперь задача № 38 будет обрабатывать эти записи одну за другой. В потоковой обработке я просто отправляю сообщения в Webhook в терминаторе forEach.
Проблема: отправка сообщений в Webhook занимает едва ли 100-200 мс. Но поток Кафки занимает около 2 секунд, чтобы обработать следующую запись. Я точно знаю, что когда-то семантически, это накладные расходы на принятие транзакций и т. Д. Но вопрос в том, занимает ли это около 2 секунд?
Пожалуйста, дайте мне знать, если я указал что-то неправильно или что-то пропустил.