cloudflow
cloudflow copied to clipboard
lightbend
Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.
I tried to write some test cases for flink streamlets. My blueprint contains two ingress that will listen kafka topics and one processor that will excute the tasks according to...
So that the Avro messages can be sent as messages in the Akka Cluster, such as in the connected-cars example. I guess this is the reason for `allow-java-serialization = on`...
With local mode, there's a limitation to use objects as a Streamlet implementation.We have decided to mandate the use of `class`es to implement Streamlets.In the context of this story, we...
Hi, I am logging this issue after conversation with @RayRoestenburg via gitter: https://gitter.im/lightbend/cloudflow?at=5ebbf38a7312422a87e1fb81 **Describe the bug** When testing Streamlets without Outlets - essentially an egress - the streamlet is not...
When trying to attach a debugger to a runLocal run, I couldn't find a way to change the JVM options, which is my preferred way of launch a remote debugger...
This epic is to ensure that an application can be deployed if schemas being compared (e.g. an outlet of streamlet1 connected to an inlet of streamlet2) are compatible according to...
Make sure metering reports correct usage, entitlement is properly checked etc.
Default parameters of a Spark Streamlet are not correctly processed, at least within the context of a unit test. e.g.: ``` "use the default value of a config parameter if...
A user tried to re-install Cloudflow using version 1.3.2 and faced this issue: “I just tried setting it up on GKE (v1.15.9-gke.22) with helm 2.14.3 and it gets consistently stuck...