I want to implement a job using the Apache Flink Statefun API and configure Kafka as a trigger. The idea is have events go into a Kafka topic, and have it then trigger a stateful function in Flink like a FaaS. Is this possible? How would it be implemented? I looked at the Kafka IO documentation but couldn't find any concrete code examples so if anyone has a simple example it would be greatly appreciated.
That's exactly what the Kafka ingress does.
There's a complete example application in https://github.com/ververica/flink-statefun-workshop that uses Kafka.