This documentation is for an unreleased version of Apache Flink Stateful Functions. We recommend you use the latest stable version.

I/O Components #

Stateful Functions' I/O components allow functions to receive and send messages to external systems. Based on the concept of Ingress (input) and Egress (output) points, and built on top of the Apache Flink® connector ecosystem, I/O components enable functions to interact with the outside world through the style of message passing.

Commonly used I/O components are bundled into the runtime by default and can be configured directly via the applications module configuration. Additionally, custom connectors for other systems can be plugged in to the runtime.

Remember, to use one of these connectors in an application, third-party components are usually required, e.g., servers for the data stores or message queues.