diff --git a/documentation/modules/ROOT/pages/connectors/cassandra.adoc b/documentation/modules/ROOT/pages/connectors/cassandra.adoc index d6b4ed703..20c55b226 100644 --- a/documentation/modules/ROOT/pages/connectors/cassandra.adoc +++ b/documentation/modules/ROOT/pages/connectors/cassandra.adoc @@ -978,6 +978,11 @@ the offset will be flushed every time. |`2048` |The maximum number of change events to dequeue each time. +|[[cassandra-property-max-queue-size-in-bytes]]<> +|`0` +|Long value for the maximum size in bytes of the blocking queue. The feature is disabled by default, it will be active if it's set with a positive long value. + + |[[cassandra-property-poll-interval-ms]]<> |`1000` |Positive integer value that specifies the number of milliseconds the commit log processor should wait during each iteration for new change events to appear in the queue. Defaults to 1000 milliseconds, or 1 second. diff --git a/documentation/modules/ROOT/pages/connectors/mongodb.adoc b/documentation/modules/ROOT/pages/connectors/mongodb.adoc index 0378a21b9..ea5fade90 100644 --- a/documentation/modules/ROOT/pages/connectors/mongodb.adoc +++ b/documentation/modules/ROOT/pages/connectors/mongodb.adoc @@ -1194,6 +1194,10 @@ The following _advanced_ configuration properties have good defaults that will w |`2048` |Positive integer value that specifies the maximum size of each batch of events that should be processed during each iteration of this connector. Defaults to 2048. +|[[mongodb-property-max-queue-size-in-bytes]]<> +|`0` +|Long value for the maximum size in bytes of the blocking queue. The feature is disabled by default, it will be active if it's set with a positive long value. + |[[mongodb-property-poll-interval-ms]]<> |`1000` |Positive integer value that specifies the number of milliseconds the connector should wait during each iteration for new change events to appear. Defaults to 1000 milliseconds, or 1 second. diff --git a/documentation/modules/ROOT/pages/connectors/mysql.adoc b/documentation/modules/ROOT/pages/connectors/mysql.adoc index a4991b027..d184b1e15 100644 --- a/documentation/modules/ROOT/pages/connectors/mysql.adoc +++ b/documentation/modules/ROOT/pages/connectors/mysql.adoc @@ -2163,6 +2163,10 @@ Setting `include.query`to `true` might expose tables or fields explicitly exclud |`2048` |Positive integer value that specifies the maximum size of each batch of events that should be processed during each iteration of this connector. Defaults to 2048. +|[[mysql-property-max-queue-size-in-bytes]]<> +|`0` +|Long value for the maximum size in bytes of the blocking queue. The feature is disabled by default, it will be active if it's set with a positive long value. + |[[mysql-property-poll-interval-ms]]<> |`1000` |Positive integer value that specifies the number of milliseconds the connector should wait for new change events to appear before it starts processing a batch of events. Defaults to 1000 milliseconds, or 1 second. diff --git a/documentation/modules/ROOT/pages/connectors/oracle.adoc b/documentation/modules/ROOT/pages/connectors/oracle.adoc index 109675448..2a12d524c 100644 --- a/documentation/modules/ROOT/pages/connectors/oracle.adoc +++ b/documentation/modules/ROOT/pages/connectors/oracle.adoc @@ -1403,6 +1403,10 @@ Note: Depending on the `_hashAlgorithm_` used, the `_salt_` selected and the act |`2048` |Positive integer value that specifies the maximum size of each batch of events that should be processed during each iteration of this connector. Defaults to 2048. +|[[oracle-property-max-queue-size-in-bytes]]<> +|`0` +|Long value for the maximum size in bytes of the blocking queue. The feature is disabled by default, it will be active if it's set with a positive long value. + |[[oracle-property-poll-interval-ms]]<> |`1000` |Positive integer value that specifies the number of milliseconds the connector should wait during each iteration for new change events to appear. Defaults to 1000 milliseconds, or 1 second. diff --git a/documentation/modules/ROOT/pages/connectors/postgresql.adoc b/documentation/modules/ROOT/pages/connectors/postgresql.adoc index f5e4ccbbe..d673b0873 100644 --- a/documentation/modules/ROOT/pages/connectors/postgresql.adoc +++ b/documentation/modules/ROOT/pages/connectors/postgresql.adoc @@ -2539,7 +2539,11 @@ A possible use case for setting these properties is large, append-only tables. Y |[[postgresql-property-max-batch-size]]<> |`10240` -|Positive integer value that specifies the maximum size of each batch of events that the connector processes. +|Positive integer value that specifies the maximum size of each batch of events that the connector processes. + +|[[postgresql-property-max-queue-size-in-bytes]]<> +|`0` +|Long value for the maximum size in bytes of the blocking queue. The feature is disabled by default, it will be active if it's set with a positive long value. |[[postgresql-property-poll-interval-ms]]<> |`1000` diff --git a/documentation/modules/ROOT/pages/connectors/sqlserver.adoc b/documentation/modules/ROOT/pages/connectors/sqlserver.adoc index cd92f55cf..bb3503d19 100644 --- a/documentation/modules/ROOT/pages/connectors/sqlserver.adoc +++ b/documentation/modules/ROOT/pages/connectors/sqlserver.adoc @@ -1886,6 +1886,10 @@ For `read_uncommitted` there are no data consistency guarantees at all (some dat |`2048` |Positive integer value that specifies the maximum size of each batch of events that should be processed during each iteration of this connector. Defaults to 2048. +|[[sqlserver-property-max-queue-size-in-bytes]]<> +|`0` +|Long value for the maximum size in bytes of the blocking queue. The feature is disabled by default, it will be active if it's set with a positive long value. + |[[sqlserver-property-heartbeat-interval-ms]]<> |`0` |Controls how frequently heartbeat messages are sent. + diff --git a/documentation/modules/ROOT/pages/connectors/vitess.adoc b/documentation/modules/ROOT/pages/connectors/vitess.adoc index 15f965335..82bc517dc 100644 --- a/documentation/modules/ROOT/pages/connectors/vitess.adoc +++ b/documentation/modules/ROOT/pages/connectors/vitess.adoc @@ -1136,7 +1136,11 @@ The following _advanced_ configuration properties have defaults that work in mos |[[vitess-property-max-batch-size]]<> |`10240` -|Positive integer value that specifies the maximum size of each batch of events that the connector processes. +|Positive integer value that specifies the maximum size of each batch of events that the connector processes. + +|[[vitess-property-max-queue-size-in-bytes]]<> +|`0` +|Long value for the maximum size in bytes of the blocking queue. The feature is disabled by default, it will be active if it's set with a positive long value. |[[vitess-property-poll-interval-ms]]<> |`1000` diff --git a/documentation/modules/ROOT/partials/modules/all-connectors/ref-connector-monitoring-snapshot-metrics.adoc b/documentation/modules/ROOT/partials/modules/all-connectors/ref-connector-monitoring-snapshot-metrics.adoc index cd77e4e1f..4171b0d30 100644 --- a/documentation/modules/ROOT/partials/modules/all-connectors/ref-connector-monitoring-snapshot-metrics.adoc +++ b/documentation/modules/ROOT/partials/modules/all-connectors/ref-connector-monitoring-snapshot-metrics.adoc @@ -62,7 +62,7 @@ Updates every 10,000 rows scanned and upon completing a table. |[[connectors-strm-metric-maxqueuesizeinbytes_{context}]]<> |`long` -|The maximum buffer of the queue in bytes. It will be enabled if max.queue.size.in.bytes is passed with a positive long value. +|The maximum buffer of the queue in bytes. It will be enabled if `max.queue.size.in.bytes` is passed with a positive long value. |[[connectors-strm-metric-currentqueuesizeinbytes_{context}]]<> |`long`