This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 745d01385c4 regen
745d01385c4 is described below
commit 745d01385c4506c519d9a0d1b202705776263f2a
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Oct 17 20:41:39 2025 +0200
regen
---
.../apache/camel/springboot/catalog/components/flink.json | 12 ++++++++++--
.../camel-flink-starter/src/main/docs/flink.json | 14 ++++++++------
.../flink/springboot/FlinkComponentConfiguration.java | 5 +++++
3 files changed, 23 insertions(+), 8 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/flink.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/flink.json
index 13a31f8edd0..7e6125fb375 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/flink.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/flink.json
@@ -24,7 +24,7 @@
"remote": true
},
"componentProperties": {
- "dataSetCallback": { "index": 0, "kind": "property", "displayName": "Data
Set Callback", "group": "producer", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.component.flink.DataSetCallback",
"deprecated": false, "autowired": false, "secret": false, "description":
"Function performing action against a DataSet." },
+ "dataSetCallback": { "index": 0, "kind": "property", "displayName": "Data
Set Callback", "group": "producer", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.component.flink.DataSetCallback",
"deprecated": true, "autowired": false, "secret": false, "description":
"Function performing action against a DataSet." },
"dataStream": { "index": 1, "kind": "property", "displayName": "Data
Stream", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "org.apache.flink.streaming.api.datastream.DataStream",
"deprecated": false, "autowired": false, "secret": false, "description":
"DataStream to compute against." },
"dataStreamCallback": { "index": 2, "kind": "property", "displayName":
"Data Stream Callback", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.flink.DataStreamCallback", "deprecated": false,
"autowired": false, "secret": false, "description": "Function performing action
against a DataStream." },
"lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
@@ -43,6 +43,14 @@
"dataSetCallback": { "index": 3, "kind": "parameter", "displayName": "Data
Set Callback", "group": "producer", "label": "", "required": false, "type":
"object", "javaType": "org.apache.camel.component.flink.DataSetCallback",
"deprecated": false, "autowired": false, "secret": false, "description":
"Function performing action against a DataSet." },
"dataStream": { "index": 4, "kind": "parameter", "displayName": "Data
Stream", "group": "producer", "label": "", "required": false, "type": "object",
"javaType": "org.apache.flink.streaming.api.datastream.DataStream",
"deprecated": false, "autowired": false, "secret": false, "description":
"DataStream to compute against." },
"dataStreamCallback": { "index": 5, "kind": "parameter", "displayName":
"Data Stream Callback", "group": "producer", "label": "", "required": false,
"type": "object", "javaType":
"org.apache.camel.component.flink.DataStreamCallback", "deprecated": false,
"autowired": false, "secret": false, "description": "Function performing action
against a DataStream." },
- "lazyStartProducer": { "index": 6, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produc [...]
+ "checkpointingMode": { "index": 6, "kind": "parameter", "displayName":
"Checkpointing Mode", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "enum", "javaType":
"java.lang.String", "enum": [ "EXACTLY_ONCE", "AT_LEAST_ONCE" ], "deprecated":
false, "autowired": false, "secret": false, "description": "Checkpointing mode:
EXACTLY_ONCE (default) or AT_LEAST_ONCE. EXACTLY_ONCE provides stronger
guarantees but may have higher overhead." },
+ "checkpointInterval": { "index": 7, "kind": "parameter", "displayName":
"Checkpoint Interval", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType":
"java.lang.Long", "deprecated": false, "autowired": false, "secret": false,
"description": "Interval in milliseconds between checkpoints. Enables
checkpointing when set. Recommended for streaming jobs to ensure fault
tolerance." },
+ "checkpointTimeout": { "index": 8, "kind": "parameter", "displayName":
"Checkpoint Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType":
"java.lang.Long", "deprecated": false, "autowired": false, "secret": false,
"description": "Timeout in milliseconds for checkpoints. Checkpoints that take
longer will be aborted." },
+ "executionMode": { "index": 9, "kind": "parameter", "displayName":
"Execution Mode", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "enum", "javaType": "java.lang.String", "enum": [
"STREAMING", "BATCH", "AUTOMATIC" ], "deprecated": false, "autowired": false,
"secret": false, "description": "Execution mode for the Flink job. Options:
STREAMING (default), BATCH, AUTOMATIC. BATCH mode is recommended for bounded
streams (batch processing)." },
+ "jobName": { "index": 10, "kind": "parameter", "displayName": "Job Name",
"group": "producer (advanced)", "label": "producer,advanced", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "Name for the Flink job.
Useful for identification in the Flink UI and logs." },
+ "lazyStartProducer": { "index": 11, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
+ "maxParallelism": { "index": 12, "kind": "parameter", "displayName": "Max
Parallelism", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "integer", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "description":
"Maximum parallelism for the Flink job. Defines the upper bound for dynamic
scaling and the number of key groups for stateful operators." },
+ "minPauseBetweenCheckpoints": { "index": 13, "kind": "parameter",
"displayName": "Min Pause Between Checkpoints", "group": "producer (advanced)",
"label": "producer,advanced", "required": false, "type": "integer", "javaType":
"java.lang.Long", "deprecated": false, "autowired": false, "secret": false,
"description": "Minimum pause in milliseconds between consecutive checkpoints.
Helps prevent checkpoint storms under heavy load." },
+ "parallelism": { "index": 14, "kind": "parameter", "displayName":
"Parallelism", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "integer", "javaType": "java.lang.Integer",
"deprecated": false, "autowired": false, "secret": false, "description":
"Parallelism for the Flink job. If not set, uses the default parallelism of the
execution environment." }
}
}
diff --git a/components-starter/camel-flink-starter/src/main/docs/flink.json
b/components-starter/camel-flink-starter/src/main/docs/flink.json
index abfe515dfc6..a6b321e5de4 100644
--- a/components-starter/camel-flink-starter/src/main/docs/flink.json
+++ b/components-starter/camel-flink-starter/src/main/docs/flink.json
@@ -25,12 +25,6 @@
"type": "java.lang.Boolean",
"sourceType":
"org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon$CustomizerProperties"
},
- {
- "name": "camel.component.flink.data-set-callback",
- "type": "org.apache.camel.component.flink.DataSetCallback",
- "description": "Function performing action against a DataSet. The option
is a org.apache.camel.component.flink.DataSetCallback type.",
- "sourceType":
"org.apache.camel.component.flink.springboot.FlinkComponentConfiguration"
- },
{
"name": "camel.component.flink.data-stream",
"type": "org.apache.flink.streaming.api.datastream.DataStream",
@@ -55,6 +49,14 @@
"description": "Whether the producer should be started lazy (on the
first message). By starting lazy you can use this to allow CamelContext and
routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and starting the [...]
"sourceType":
"org.apache.camel.component.flink.springboot.FlinkComponentConfiguration",
"defaultValue": false
+ },
+ {
+ "name": "camel.component.flink.data-set-callback",
+ "type": "org.apache.camel.component.flink.DataSetCallback",
+ "description": "Function performing action against a DataSet. The option
is a org.apache.camel.component.flink.DataSetCallback type.",
+ "sourceType":
"org.apache.camel.component.flink.springboot.FlinkComponentConfiguration",
+ "deprecated": true,
+ "deprecation": {}
}
],
"hints": [],
diff --git
a/components-starter/camel-flink-starter/src/main/java/org/apache/camel/component/flink/springboot/FlinkComponentConfiguration.java
b/components-starter/camel-flink-starter/src/main/java/org/apache/camel/component/flink/springboot/FlinkComponentConfiguration.java
index d6648b8fc37..e0982320609 100644
---
a/components-starter/camel-flink-starter/src/main/java/org/apache/camel/component/flink/springboot/FlinkComponentConfiguration.java
+++
b/components-starter/camel-flink-starter/src/main/java/org/apache/camel/component/flink/springboot/FlinkComponentConfiguration.java
@@ -21,6 +21,7 @@ import org.apache.camel.component.flink.DataStreamCallback;
import org.apache.camel.spring.boot.ComponentConfigurationPropertiesCommon;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.springframework.boot.context.properties.ConfigurationProperties;
+import
org.springframework.boot.context.properties.DeprecatedConfigurationProperty;
/**
* Send DataSet jobs to an Apache Flink cluster.
@@ -41,6 +42,7 @@ public class FlinkComponentConfiguration
* Function performing action against a DataSet. The option is a
* org.apache.camel.component.flink.DataSetCallback type.
*/
+ @Deprecated
private DataSetCallback dataSetCallback;
/**
* DataStream to compute against. The option is a
@@ -73,10 +75,13 @@ public class FlinkComponentConfiguration
*/
private Boolean autowiredEnabled = true;
+ @Deprecated
+ @DeprecatedConfigurationProperty
public DataSetCallback getDataSetCallback() {
return dataSetCallback;
}
+ @Deprecated
public void setDataSetCallback(DataSetCallback dataSetCallback) {
this.dataSetCallback = dataSetCallback;
}
