This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new a92cd7d [create-pull-request] automated change
a92cd7d is described below
commit a92cd7d88846ba91fbd0dbeb5055801b2733dd6b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sun Jun 13 04:04:01 2021 +0000
[create-pull-request] automated change
---
.../resources/connectors/camel-mongodb-sink.json | 43 ----------------------
.../generated/resources/camel-mongodb-sink.json | 43 ----------------------
.../docs/camel-mongodb-kafka-sink-connector.adoc | 9 +----
.../mongodb/CamelMongodbSinkConnectorConfig.java | 28 --------------
.../camel-mongodb-kafka-sink-connector.adoc | 13 +------
5 files changed, 2 insertions(+), 134 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-sink.json
index 080fa9f..8f61221 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-sink.json
@@ -143,12 +143,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.streamFilter": {
- "name": "camel.sink.endpoint.streamFilter",
- "description": "Filter condition for change streams
consumer.",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.password": {
"name": "camel.sink.endpoint.password",
"description": "User password for mongodb connection",
@@ -161,43 +155,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.persistentId": {
- "name": "camel.sink.endpoint.persistentId",
- "description": "One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId.",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.persistentTailTracking": {
- "name": "camel.sink.endpoint.persistentTailTracking",
- "description": "Enable persistent tail tracking, which
is a mechanism to keep track of the last consumed message across system
restarts. The next time the system is up, the endpoint will recover the cursor
from the point where it last stopped slurping records.",
- "defaultValue": "false",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.tailTrackCollection": {
- "name": "camel.sink.endpoint.tailTrackCollection",
- "description": "Collection where tail tracking
information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default.",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.tailTrackDb": {
- "name": "camel.sink.endpoint.tailTrackDb",
- "description": "Indicates what database the tail
tracking mechanism will persist to. If not specified, the current database will
be picked by default. Dynamicity will not be taken into account even if
enabled, i.e. the tail tracking database will not vary past endpoint
initialisation.",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.tailTrackField": {
- "name": "camel.sink.endpoint.tailTrackField",
- "description": "Field where the last tracked value will
be placed. If not specified, MongoDbTailTrackingConfig#DEFAULT_FIELD will be
used by default.",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.tailTrackIncreasingField": {
- "name": "camel.sink.endpoint.tailTrackIncreasingField",
- "description": "Correlation field in the incoming
record which is of increasing nature and will be used to position the tailing
cursor every time it is generated. The cursor will be (re)created with a query
of type: tailTrackIncreasingField greater than lastValue (possibly recovered
from persistent tail tracking). Can be of type Integer, Date, String, etc.
NOTE: No support for dot notation at the current time, so the field should be
at the top level of the document.",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.mongodb.mongoConnection": {
"name": "camel.component.mongodb.mongoConnection",
"description": "Shared client used for connection. All
endpoints generated from the component will share this connection client.",
diff --git
a/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-sink.json
b/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-sink.json
index 080fa9f..8f61221 100644
---
a/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-sink.json
+++
b/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-sink.json
@@ -143,12 +143,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.streamFilter": {
- "name": "camel.sink.endpoint.streamFilter",
- "description": "Filter condition for change streams
consumer.",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.password": {
"name": "camel.sink.endpoint.password",
"description": "User password for mongodb connection",
@@ -161,43 +155,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.persistentId": {
- "name": "camel.sink.endpoint.persistentId",
- "description": "One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId.",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.persistentTailTracking": {
- "name": "camel.sink.endpoint.persistentTailTracking",
- "description": "Enable persistent tail tracking, which
is a mechanism to keep track of the last consumed message across system
restarts. The next time the system is up, the endpoint will recover the cursor
from the point where it last stopped slurping records.",
- "defaultValue": "false",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.tailTrackCollection": {
- "name": "camel.sink.endpoint.tailTrackCollection",
- "description": "Collection where tail tracking
information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default.",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.tailTrackDb": {
- "name": "camel.sink.endpoint.tailTrackDb",
- "description": "Indicates what database the tail
tracking mechanism will persist to. If not specified, the current database will
be picked by default. Dynamicity will not be taken into account even if
enabled, i.e. the tail tracking database will not vary past endpoint
initialisation.",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.tailTrackField": {
- "name": "camel.sink.endpoint.tailTrackField",
- "description": "Field where the last tracked value will
be placed. If not specified, MongoDbTailTrackingConfig#DEFAULT_FIELD will be
used by default.",
- "priority": "MEDIUM",
- "required": "false"
- },
- "camel.sink.endpoint.tailTrackIncreasingField": {
- "name": "camel.sink.endpoint.tailTrackIncreasingField",
- "description": "Correlation field in the incoming
record which is of increasing nature and will be used to position the tailing
cursor every time it is generated. The cursor will be (re)created with a query
of type: tailTrackIncreasingField greater than lastValue (possibly recovered
from persistent tail tracking). Can be of type Integer, Date, String, etc.
NOTE: No support for dot notation at the current time, so the field should be
at the top level of the document.",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.mongodb.mongoConnection": {
"name": "camel.component.mongodb.mongoConnection",
"description": "Shared client used for connection. All
endpoints generated from the component will share this connection client.",
diff --git
a/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-sink-connector.adoc
b/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-sink-connector.adoc
index 63599c7..c969992 100644
---
a/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-sink-connector.adoc
+++
b/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSinkConnecto
----
-The camel-mongodb sink connector supports 27 options, which are listed below.
+The camel-mongodb sink connector supports 20 options, which are listed below.
@@ -46,15 +46,8 @@ The camel-mongodb sink connector supports 27 options, which
are listed below.
| *camel.sink.endpoint.readPreference* | Configure how MongoDB clients route
read operations to the members of a replica set. Possible values are PRIMARY,
PRIMARY_PREFERRED, SECONDARY, SECONDARY_PREFERRED or NEAREST One of: [PRIMARY]
[PRIMARY_PREFERRED] [SECONDARY] [SECONDARY_PREFERRED] [NEAREST] | "PRIMARY" |
false | MEDIUM
| *camel.sink.endpoint.writeConcern* | Configure the connection bean with the
level of acknowledgment requested from MongoDB for write operations to a
standalone mongod, replicaset or cluster. Possible values are ACKNOWLEDGED, W1,
W2, W3, UNACKNOWLEDGED, JOURNALED or MAJORITY. One of: [ACKNOWLEDGED] [W1] [W2]
[W3] [UNACKNOWLEDGED] [JOURNALED] [MAJORITY] | "ACKNOWLEDGED" | false | MEDIUM
| *camel.sink.endpoint.writeResultAsHeader* | In write operations, it
determines whether instead of returning WriteResult as the body of the OUT
message, we transfer the IN message to the OUT and attach the WriteResult as a
header. | false | false | MEDIUM
-| *camel.sink.endpoint.streamFilter* | Filter condition for change streams
consumer. | null | false | MEDIUM
| *camel.sink.endpoint.password* | User password for mongodb connection | null
| false | MEDIUM
| *camel.sink.endpoint.username* | Username for mongodb connection | null |
false | MEDIUM
-| *camel.sink.endpoint.persistentId* | One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId. | null | false | MEDIUM
-| *camel.sink.endpoint.persistentTailTracking* | Enable persistent tail
tracking, which is a mechanism to keep track of the last consumed message
across system restarts. The next time the system is up, the endpoint will
recover the cursor from the point where it last stopped slurping records. |
false | false | MEDIUM
-| *camel.sink.endpoint.tailTrackCollection* | Collection where tail tracking
information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default. | null |
false | MEDIUM
-| *camel.sink.endpoint.tailTrackDb* | Indicates what database the tail
tracking mechanism will persist to. If not specified, the current database will
be picked by default. Dynamicity will not be taken into account even if
enabled, i.e. the tail tracking database will not vary past endpoint
initialisation. | null | false | MEDIUM
-| *camel.sink.endpoint.tailTrackField* | Field where the last tracked value
will be placed. If not specified, MongoDbTailTrackingConfig#DEFAULT_FIELD will
be used by default. | null | false | MEDIUM
-| *camel.sink.endpoint.tailTrackIncreasingField* | Correlation field in the
incoming record which is of increasing nature and will be used to position the
tailing cursor every time it is generated. The cursor will be (re)created with
a query of type: tailTrackIncreasingField greater than lastValue (possibly
recovered from persistent tail tracking). Can be of type Integer, Date, String,
etc. NOTE: No support for dot notation at the current time, so the field should
be at the top level of [...]
| *camel.component.mongodb.mongoConnection* | Shared client used for
connection. All endpoints generated from the component will share this
connection client. | null | false | MEDIUM
| *camel.component.mongodb.lazyStartProducer* | 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 [...]
| *camel.component.mongodb.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
diff --git
a/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSinkConnectorConfig.java
b/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSinkConnectorConfig.java
index ff3e1b3..6f20214 100644
---
a/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSinkConnectorConfig.java
+++
b/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSinkConnectorConfig.java
@@ -69,33 +69,12 @@ public class CamelMongodbSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_CONF =
"camel.sink.endpoint.writeResultAsHeader";
public static final String
CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_DOC = "In write operations,
it determines whether instead of returning WriteResult as the body of the OUT
message, we transfer the IN message to the OUT and attach the WriteResult as a
header.";
public static final Boolean
CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_DEFAULT = false;
- public static final String CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_CONF
= "camel.sink.endpoint.streamFilter";
- public static final String CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_DOC =
"Filter condition for change streams consumer.";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_DEFAULT = null;
public static final String CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_CONF =
"camel.sink.endpoint.password";
public static final String CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_DOC =
"User password for mongodb connection";
public static final String CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_DEFAULT =
null;
public static final String CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_CONF =
"camel.sink.endpoint.username";
public static final String CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_DOC =
"Username for mongodb connection";
public static final String CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_DEFAULT =
null;
- public static final String CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_CONF
= "camel.sink.endpoint.persistentId";
- public static final String CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_DOC =
"One tail tracking collection can host many trackers for several tailable
consumers. To keep them separate, each tracker should have its own unique
persistentId.";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_DEFAULT = null;
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_CONF =
"camel.sink.endpoint.persistentTailTracking";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_DOC = "Enable persistent
tail tracking, which is a mechanism to keep track of the last consumed message
across system restarts. The next time the system is up, the endpoint will
recover the cursor from the point where it last stopped slurping records.";
- public static final Boolean
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_DEFAULT = false;
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_CONF =
"camel.sink.endpoint.tailTrackCollection";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_DOC = "Collection where tail
tracking information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default.";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_DEFAULT = null;
- public static final String CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_DB_CONF
= "camel.sink.endpoint.tailTrackDb";
- public static final String CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_DB_DOC =
"Indicates what database the tail tracking mechanism will persist to. If not
specified, the current database will be picked by default. Dynamicity will not
be taken into account even if enabled, i.e. the tail tracking database will not
vary past endpoint initialisation.";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_DB_DEFAULT = null;
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_FIELD_CONF =
"camel.sink.endpoint.tailTrackField";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_FIELD_DOC = "Field where the last
tracked value will be placed. If not specified,
MongoDbTailTrackingConfig#DEFAULT_FIELD will be used by default.";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_FIELD_DEFAULT = null;
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_INCREASING_FIELD_CONF =
"camel.sink.endpoint.tailTrackIncreasingField";
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_INCREASING_FIELD_DOC = "Correlation
field in the incoming record which is of increasing nature and will be used to
position the tailing cursor every time it is generated. The cursor will be
(re)created with a query of type: tailTrackIncreasingField greater than
lastValue (possibly recovered from persistent tail tracking). Can be of type
Integer, Date, String, etc. NOTE: No support for dot notation at the current
time, [...]
- public static final String
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_INCREASING_FIELD_DEFAULT = null;
public static final String
CAMEL_SINK_MONGODB_COMPONENT_MONGO_CONNECTION_CONF =
"camel.component.mongodb.mongoConnection";
public static final String
CAMEL_SINK_MONGODB_COMPONENT_MONGO_CONNECTION_DOC = "Shared client used for
connection. All endpoints generated from the component will share this
connection client.";
public static final String
CAMEL_SINK_MONGODB_COMPONENT_MONGO_CONNECTION_DEFAULT = null;
@@ -133,15 +112,8 @@ public class CamelMongodbSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_READ_PREFERENCE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_READ_PREFERENCE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_READ_PREFERENCE_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_WRITE_CONCERN_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_WRITE_CONCERN_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_WRITE_CONCERN_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_DOC);
- conf.define(CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_DOC);
- conf.define(CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_DOC);
- conf.define(CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_DOC);
- conf.define(CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_DOC);
- conf.define(CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_DB_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_DB_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_DB_DOC);
- conf.define(CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_FIELD_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_FIELD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_FIELD_DOC);
-
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_INCREASING_FIELD_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_INCREASING_FIELD_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_INCREASING_FIELD_DOC);
conf.define(CAMEL_SINK_MONGODB_COMPONENT_MONGO_CONNECTION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_COMPONENT_MONGO_CONNECTION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_COMPONENT_MONGO_CONNECTION_DOC);
conf.define(CAMEL_SINK_MONGODB_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_MONGODB_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_MONGODB_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_MONGODB_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_COMPONENT_AUTOWIRED_ENABLED_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-sink-connector.adoc
index 3afe0f3..6627490 100644
--- a/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSinkConnecto
----
-The camel-mongodb sink connector supports 27 options, which are listed below.
+The camel-mongodb sink connector supports 20 options, which are listed below.
@@ -46,15 +46,8 @@ The camel-mongodb sink connector supports 27 options, which
are listed below.
| *camel.sink.endpoint.readPreference* | Configure how MongoDB clients route
read operations to the members of a replica set. Possible values are PRIMARY,
PRIMARY_PREFERRED, SECONDARY, SECONDARY_PREFERRED or NEAREST One of: [PRIMARY]
[PRIMARY_PREFERRED] [SECONDARY] [SECONDARY_PREFERRED] [NEAREST] | "PRIMARY" |
false | MEDIUM
| *camel.sink.endpoint.writeConcern* | Configure the connection bean with the
level of acknowledgment requested from MongoDB for write operations to a
standalone mongod, replicaset or cluster. Possible values are ACKNOWLEDGED, W1,
W2, W3, UNACKNOWLEDGED, JOURNALED or MAJORITY. One of: [ACKNOWLEDGED] [W1] [W2]
[W3] [UNACKNOWLEDGED] [JOURNALED] [MAJORITY] | "ACKNOWLEDGED" | false | MEDIUM
| *camel.sink.endpoint.writeResultAsHeader* | In write operations, it
determines whether instead of returning WriteResult as the body of the OUT
message, we transfer the IN message to the OUT and attach the WriteResult as a
header. | false | false | MEDIUM
-| *camel.sink.endpoint.streamFilter* | Filter condition for change streams
consumer. | null | false | MEDIUM
| *camel.sink.endpoint.password* | User password for mongodb connection | null
| false | MEDIUM
| *camel.sink.endpoint.username* | Username for mongodb connection | null |
false | MEDIUM
-| *camel.sink.endpoint.persistentId* | One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId. | null | false | MEDIUM
-| *camel.sink.endpoint.persistentTailTracking* | Enable persistent tail
tracking, which is a mechanism to keep track of the last consumed message
across system restarts. The next time the system is up, the endpoint will
recover the cursor from the point where it last stopped slurping records. |
false | false | MEDIUM
-| *camel.sink.endpoint.tailTrackCollection* | Collection where tail tracking
information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default. | null |
false | MEDIUM
-| *camel.sink.endpoint.tailTrackDb* | Indicates what database the tail
tracking mechanism will persist to. If not specified, the current database will
be picked by default. Dynamicity will not be taken into account even if
enabled, i.e. the tail tracking database will not vary past endpoint
initialisation. | null | false | MEDIUM
-| *camel.sink.endpoint.tailTrackField* | Field where the last tracked value
will be placed. If not specified, MongoDbTailTrackingConfig#DEFAULT_FIELD will
be used by default. | null | false | MEDIUM
-| *camel.sink.endpoint.tailTrackIncreasingField* | Correlation field in the
incoming record which is of increasing nature and will be used to position the
tailing cursor every time it is generated. The cursor will be (re)created with
a query of type: tailTrackIncreasingField greater than lastValue (possibly
recovered from persistent tail tracking). Can be of type Integer, Date, String,
etc. NOTE: No support for dot notation at the current time, so the field should
be at the top level of [...]
| *camel.component.mongodb.mongoConnection* | Shared client used for
connection. All endpoints generated from the component will share this
connection client. | null | false | MEDIUM
| *camel.component.mongodb.lazyStartProducer* | 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 [...]
| *camel.component.mongodb.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
@@ -75,8 +68,4 @@ The camel-mongodb sink connector has no transforms out of the
box.
The camel-mongodb sink connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
