cloudflow
cloudflow copied to clipboard
lightbend
Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.
**Is your feature request related to a problem? Please describe.** A way to use map-config in streamlet configuration **Is your feature request related to a specific runtime of cloudflow or...
This can be used to stop/pause processing of parts of the application, which can be useful in many scenarios. It also gives some more control to the user. We envisioned...
The documentation example (2.0.10) at https://cloudflow.io/docs/2.0.10/get-started/setup-example-project-configure-build.html links to example code:  The links go to https://github.com/lightbend/cloudflow/tree/master/examples/snippets/modules/ROOT/examples/sensor-data-scala. However, from there * it's somewhat hard to download the code * it links...
Has any consideration been given to the distribution of Cloudflow Docker image "from scratch" i.e. without a base image? The benefits of doing so include: * less concern over the...
It is currently hard for users to track which versions of dependencies they are getting and which versions they should use when adding extra dependencies to their projects. This results...
**Is your feature request related to a problem? Please describe.** I noticed that when errors occurs in the Flink streamlet then some messages duplicates in the outlet Kafka topic. To...
core/cloudflow-akka/src/main/resources/reference.conf tries to override some config properties from Alpakka Kafka. That will not (always) work since classpath order is undefined. One library can't override reference.conf properties of another library.
Trevor got into some trouble on a Java project, when he forgot to set the schemaCodeGenerator ``` schemaCodeGenerator := SchemaCodeGenerator.Java, ``` He only found out when running his app that...
When executing kubectl cloudflow version the CLI should also query the cluster for the version of the operator(s) installed and report that along with the client version. The Cloudflow operator...
I have a problem changing the flink application in my pipeline. The problem is this: for example, I want to change the amount of memory for the task мanager in...
