Details
-
New Feature
-
Status: Closed
-
Major
-
Resolution: Fixed
-
statefun-2.0.0
Description
Excerpt from: https://github.com/apache/flink-statefun/pull/32#discussion_r383644382
Currently, you'd need to provide a complete Configuration as dynamic properties when constructing a StatefulFunctionsAppContainers.
It'll be nicer if this is built like this:
public StatefulFunctionsAppContainers verificationApp = new StatefulFunctionsAppContainers("sanity-verification", 2) .withModuleGlobalConfiguration("kafka-broker", kafka.getBootstrapServers()) .withConfiguration(ConfigOption option, configValue)
And by default the StatefulFunctionsAppContainers just only has the configs in the base template flink-conf.yaml.
This would require lazy construction of the containers on beforeTest.
Attachments
Issue Links
- links to