Блог

Я хотел бы предоставить HTTP API в качестве источника Flink в Java, чтобы я мог получать данные по HTTP-запросу, возвращать ответ вызывающему абоненту и передавать эти данные следующему оператору Flink.

Я не нашел никакой документации об этом, а также я хотел бы получить пример реализации для этого.

вы можете использовать SourceFunction.

https://github.com/apache/flink/blob/f6d40bcfd89e67647d1f9cb41fa8be613d122494/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java

К вашему сведению