По умолчанию Сиддхи публикует неблокирующим способом. Следовательно, потоки в Siddhi не будут заблокированы, если вы не настроите его для обратного давления, используя Siddhi Error processing . Если не удается установить соединение, Сиддхи автоматически повторяет попытку с помощью механизма повторной попытки отката.
Вы можете использовать Обработка ошибок Сиддхи , чтобы обработать ошибки вручную. С обработкой ошибок в Sink вы можете обрабатывать случаи ошибок, используя 3 подхода.
- Записывать и удалять событие
- Публикация потоков ожидает в режиме отката и повторной попытки
- Перенесите сбойные события в выделенный поток и используйте последующие события в соответствии с вашим требованием.
Я также считаю, что пользователям будет удобнее, если эта поддержка будет предоставляться изначально,Поэтому я создал проблему , чтобы вызвать запрос функции.