Есть ли способ установить задержку для сообщения, отправляемого производителем kafka?

Итак, установите интервал ожидания или таймер в цикле опроса потребителей (или производителя, но я бы рекомендовал потребителя) ... Вы не пробовали это?

Я хочу, чтобы задержка произошла в конце кафки, а не в конце моего основного проекта. Я думаю, что интервал таймера и сон, которые вы предложили, будут внутри основного проекта

У вас есть два конца трубы Кафки. Я обычно предлагаю получать события в реальном времени как можно быстрее, тогда потребители могут быть настолько медленными, насколько они хотят, в течение периода хранения темы.

Меня беспокоит не сохранение темы, а задержка получения в самом сообщении. Вот что мне нужно. Мне нужен вызов функции после тайм-аута 90 секунд. Моя проблема в том, что я не могу найти эту функциональность в кафке

Сожалею, что такого не существует в Кафке. Вам нужно реализовать это самостоятельно как внешний клиент.

Например, в Spark Streaming вы можете установить размер окна пакета 90 секунд. Я уверен, что в аналогичных фреймворках вы можете определять временные окна, к которым может применяться агрегатная функция, если это то, что вы пытаетесь сделать.