У меня есть конечная точка REST API, на данный момент 3 конечные точки, но количество конечных точек может быть увеличено в будущем. Он выдает данные каждую секунду. Итак, я хотел передать данные в потоковом режиме и сохранить в Kafka.
Я прочитал несколько статей о вызове REST API с использованием Flink Asyn c IO call, но не получил простого примера из источников.
Ссылка: Flink 1.6 Asyn c IO - Как увеличить пропускную способность при обогащении потока с помощью вызова службы REST?
Любой ввод очень ценится, спасибо!