apache-kafkaapache-flinkflink-statefun

Flink Statefun API Kafka trigger


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.


Solution

  • 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.