Skip to content

Commit ca9cd58

Browse files
committed
Define different set of advanced parameters for redeploy.
1 parent ca90d04 commit ca9cd58

File tree

1 file changed

+19
-1
lines changed

1 file changed

+19
-1
lines changed

engine/flink/kafka-components-utils/src/main/scala/pl/touk/nussknacker/engine/kafka/source/flink/FlinkKafkaSource.scala

Lines changed: 19 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,25 @@ class FlinkKafkaSource[T](
104104
label = Some("Offset reset strategy"),
105105
hintText = None
106106
),
107-
)
107+
),
108+
ScenarioActionName("REDEPLOY") -> Map(
109+
OFFSET_RESET_STRATEGY_PARAM_NAME -> ParameterConfig(
110+
defaultValue = Some(OffsetResetStrategy.None.toString),
111+
editor = Some(
112+
FixedValuesWithRadioParameterEditor(
113+
List(
114+
FixedExpressionValue(
115+
OffsetResetStrategy.None.toString,
116+
s"Resume reading where it previously stopped"
117+
),
118+
)
119+
)
120+
),
121+
validators = None,
122+
label = Some("Offset reset strategy"),
123+
hintText = None
124+
),
125+
),
108126
)
109127
}
110128

0 commit comments

Comments
 (0)