Hello everyone,
Currently I'm busy setting up a pipeline with Stateful Functions using a deployment of the standard docker image "apache/flink-statefun" to kubernetes. It has been going smoothly so far and I love the whole toolset. But now I want to add Egress modules for both Opensearch (= ElasticSearch protocol) and ScyllaDB (= Cassandra protocol). The documentation at https://ci.apache.org/projects/flink/flink-statefun-docs-master/docs/io-modu le/flink-connectors/ indicates that I can somehow simply plug in the standard Flink datastream connectors for ElasticSearch and Cassandra. But I didn't get how exactly. It says "include the dependency in your pom". Does that mean that I need to build the stateful functions java application and afterwards the docker image? That would be a bit unfortunate in terms of long-term maintenance effort, because I would need to keep my local checkout in sync with the official repositories and rebuild every now and then. Maybe this can also be added on top of the existing docker image by adding some jar file to some magic plugin folder? Sorry, I hope this doesn't sound captious. I just want to understand and do it the right way. Maybe there is also some minimal example? I didn't find any in the playground nor on stackoverflow or the mailing lists. Thanks, Christian Krudewig
smime.p7s
Description: S/MIME cryptographic signature
