You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by David Dixon <da...@creditkarma.com> on 2022/03/16 20:18:13 UTC

Stateful function with GCP Pub/Sub ingress/egress

The statefun docs have some nice examples of how to use Kafka and Kinesis
for ingress/egress in conjunction with a function. Is there some
documentation or example code I could reference to do the same with a GCP
Pub/Sub topic? Thanks.

Dave