diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/legacy/BinlogReaderMetrics.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/legacy/BinlogReaderMetrics.java index c1d07c1cf..9c2be5455 100644 --- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/legacy/BinlogReaderMetrics.java +++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/legacy/BinlogReaderMetrics.java @@ -151,6 +151,10 @@ public void setMilliSecondsBehindSource(long value) { milliSecondsBehindMaster.set(value); } + /** + * @deprecated Superseded by the 'Captured Tables' metric. Use {@link #getCapturedTables()}. + * Scheduled for removal in a future release. + */ @Override @Deprecated public String[] getMonitoredTables() { diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/legacy/ReaderMetricsMXBean.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/legacy/ReaderMetricsMXBean.java index 7925bf3aa..3d6ca56b0 100644 --- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/legacy/ReaderMetricsMXBean.java +++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/legacy/ReaderMetricsMXBean.java @@ -13,6 +13,10 @@ */ public interface ReaderMetricsMXBean { + /** + * @deprecated Superseded by the 'Captured Tables' metric. Use {@link #getCapturedTables()}. + * Scheduled for removal in a future release. + */ @Deprecated String[] getMonitoredTables(); diff --git a/debezium-core/src/main/java/io/debezium/pipeline/metrics/ChangeEventSourceMetricsMXBean.java b/debezium-core/src/main/java/io/debezium/pipeline/metrics/ChangeEventSourceMetricsMXBean.java index 6a80a9755..719bc03c1 100644 --- a/debezium-core/src/main/java/io/debezium/pipeline/metrics/ChangeEventSourceMetricsMXBean.java +++ b/debezium-core/src/main/java/io/debezium/pipeline/metrics/ChangeEventSourceMetricsMXBean.java @@ -22,6 +22,10 @@ public interface ChangeEventSourceMetricsMXBean { long getNumberOfErroneousEvents(); + /** + * @deprecated Superseded by the 'Captured Tables' metric. Use {@link #getCapturedTables()}. + * Scheduled for removal in a future release. + */ @Deprecated String[] getMonitoredTables(); diff --git a/debezium-core/src/main/java/io/debezium/pipeline/metrics/SnapshotChangeEventSourceMetrics.java b/debezium-core/src/main/java/io/debezium/pipeline/metrics/SnapshotChangeEventSourceMetrics.java index 3c96b8018..f6518d140 100644 --- a/debezium-core/src/main/java/io/debezium/pipeline/metrics/SnapshotChangeEventSourceMetrics.java +++ b/debezium-core/src/main/java/io/debezium/pipeline/metrics/SnapshotChangeEventSourceMetrics.java @@ -84,6 +84,10 @@ public long getSnapshotDurationInSeconds() { return (stopMillis - startMillis) / 1000L; } + /** + * @deprecated Superseded by the 'Captured Tables' metric. Use {@link #getCapturedTables()}. + * Scheduled for removal in a future release. + */ @Override @Deprecated public String[] getMonitoredTables() { diff --git a/debezium-core/src/main/java/io/debezium/pipeline/metrics/StreamingChangeEventSourceMetrics.java b/debezium-core/src/main/java/io/debezium/pipeline/metrics/StreamingChangeEventSourceMetrics.java index 32575d9dd..9ec6a1e20 100644 --- a/debezium-core/src/main/java/io/debezium/pipeline/metrics/StreamingChangeEventSourceMetrics.java +++ b/debezium-core/src/main/java/io/debezium/pipeline/metrics/StreamingChangeEventSourceMetrics.java @@ -50,6 +50,10 @@ public boolean isConnected() { return this.connected.get(); } + /** + * @deprecated Superseded by the 'Captured Tables' metric. Use {@link #getCapturedTables()}. + * Scheduled for removal in a future release. + */ @Override @Deprecated public String[] getMonitoredTables() { diff --git a/documentation/modules/ROOT/pages/connectors/mysql.adoc b/documentation/modules/ROOT/pages/connectors/mysql.adoc index 241f63ea0..f307205f7 100644 --- a/documentation/modules/ROOT/pages/connectors/mysql.adoc +++ b/documentation/modules/ROOT/pages/connectors/mysql.adoc @@ -2416,6 +2416,15 @@ The safe default is `false`. Skipping should be used only with care as it can lead to data loss or mangling when the binlog is being processed. |[[mysql-property-database-history-store-only-monitored-tables-ddl]]<> +_deprecated and scheduled for removal in a future release_ +|`false` +|A Boolean value that specifies whether the connector should record all DDL statements + + + +`true` records only those DDL statements that are relevant to tables whose changes are being captured by {prodname}. Set to `true` with care because missing data might become necessary if you change which tables have their changes captured. + + + +The safe default is `false`. + +|[[mysql-property-database-history-store-only-captured-tables-ddl]]<> |`false` |A Boolean value that specifies whether the connector should record all DDL statements + + diff --git a/documentation/modules/ROOT/partials/modules/all-connectors/ref-connector-monitoring-streaming-metrics.adoc b/documentation/modules/ROOT/partials/modules/all-connectors/ref-connector-monitoring-streaming-metrics.adoc index 2f9bcfe5c..d7d595627 100644 --- a/documentation/modules/ROOT/partials/modules/all-connectors/ref-connector-monitoring-streaming-metrics.adoc +++ b/documentation/modules/ROOT/partials/modules/all-connectors/ref-connector-monitoring-streaming-metrics.adoc @@ -19,9 +19,14 @@ |The number of events that have been filtered by include/exclude list filtering rules configured on the connector. |[[connectors-strm-metric-monitoredtables_{context}]]<> +_deprecated and scheduled for removal in a future release_ |`string[]` |The list of tables that are monitored by the connector. +|[[connectors-strm-metric-capturedtables_{context}]]<> +|`string[]` +|The list of tables that are captured by the connector. + |[[connectors-strm-metric-queuetotalcapacity_{context}]]<> |`int` |The length the queue used to pass events between the streamer and the main Kafka Connect loop.