Предоставляет ли flink способ периодически запрашивать API и создавать из него объект потока данных для дальнейшей обработки?
В настоящее время мы отправляем сообщения на кафку и читаем кафку. Есть ли способ опрашивать API напрямую через Flink?
Я не знаю о таком разъеме источника для Flink, но было бы относительно просто реализовать его.Есть примеры, которые делают именно это, но с запросом к базе данных;один из них может послужить шаблоном для начала работы.