Я использую Knative Eventing (источник Kafka, он считывает данные из кластера kafka) для запуска службы потребителя, если событие / сообщение не было успешно обработано (может быть любая причина), я хочу повторно отправить сообщение автоматически. Я пробовал читать документы и справочник по API, и неясно, возможно ли это.
Проблема: в Knative после того, как KafkaSource отправляет сообщение в службу потребителя, служба потребителя обрабатывает запрос и отправляет ответ с кодом ошибки http (в основном обработка сообщения не удалась) и отображается как задержка (ожидающая) в группе потребителей.
Ожидается: в этом сценарии нужно повторно доставить то же сообщение перед обработкой следующего последовательного запроса. возможно ли из источника Kafka повторно доставить сообщение или Consumer Service повторно доставить неудавшиеся запросы?
Большое спасибо !!
Шринивас П.
