-
Notifications
You must be signed in to change notification settings - Fork 187
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
ba8f3c4
commit 188e95e
Showing
242 changed files
with
1,842 additions
and
1,796 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -2426,7 +2426,7 @@ <h3 id="about-the-debezium-db2-connector-schema-change-topic"><a class="anchor" | |
| }, | ||
| "payload": { | ||
| "source": { | ||
| "version": "3.0.4.Final", | ||
| "version": "3.0.5.Final", | ||
| "connector": "db2", | ||
| "name": "db2", | ||
| "ts_ms": 0, | ||
|
|
@@ -3166,7 +3166,7 @@ <h3 id="db2-create-events"><a class="anchor" href="#db2-create-events"></a><em>c | |
| "EMAIL": "[email protected]" | ||
| }, | ||
| "source": { <i class="conum" data-value="8"></i><b>(8)</b> | ||
| "version": "3.0.4.Final", | ||
| "version": "3.0.5.Final", | ||
| "connector": "db2", | ||
| "name": "myconnector", | ||
| "ts_ms": 1559729468470, | ||
|
|
@@ -3342,7 +3342,7 @@ <h3 id="db2-update-events"><a class="anchor" href="#db2-update-events"></a><em>u | |
| "EMAIL": "[email protected]" | ||
| }, | ||
| "source": { <i class="conum" data-value="3"></i><b>(3)</b> | ||
| "version": "3.0.4.Final", | ||
| "version": "3.0.5.Final", | ||
| "connector": "db2", | ||
| "name": "myconnector", | ||
| "ts_ms": 1559729995937, | ||
|
|
@@ -3473,7 +3473,7 @@ <h3 id="db2-delete-events"><a class="anchor" href="#db2-delete-events"></a><em>d | |
| }, | ||
| "after": null, <i class="conum" data-value="2"></i><b>(2)</b> | ||
| "source": { <i class="conum" data-value="3"></i><b>(3)</b> | ||
| "version": "3.0.4.Final", | ||
| "version": "3.0.5.Final", | ||
| "connector": "db2", | ||
| "name": "myconnector", | ||
| "ts_ms": 1559730445243, | ||
|
|
@@ -4394,13 +4394,13 @@ <h2 id="db2-deploying-a-connector"><a class="anchor" href="#db2-deploying-a-conn | |
| <div class="title">Procedure</div> | ||
| <ol class="arabic"> | ||
| <li> | ||
| <p>Download the <a href="https://repo1.maven.org/maven2/io/debezium/debezium-connector-db2/3.0.4.Final/debezium-connector-db2-3.0.4.Final-plugin.tar.gz">Debezium Db2 connector plug-in archive</a> from Maven Central.</p> | ||
| <p>Download the <a href="https://repo1.maven.org/maven2/io/debezium/debezium-connector-db2/3.0.5.Final/debezium-connector-db2-3.0.5.Final-plugin.tar.gz">Debezium Db2 connector plug-in archive</a> from Maven Central.</p> | ||
| </li> | ||
| <li> | ||
| <p>Extract the JAR files into your Kafka Connect environment.</p> | ||
| </li> | ||
| <li> | ||
| <p>Download the <a href="https://repo1.maven.org/maven2/com/ibm/db2/jcc/11.5.0.0/jcc-11.5.0.0.jar">JDBC driver for Db2</a> from Maven Central, and extract the downloaded driver file to the directory that contains the Debezium Db2 connector JAR file (that is, <code>debezium-connector-db2-3.0.4.Final.jar</code>).</p> | ||
| <p>Download the <a href="https://repo1.maven.org/maven2/com/ibm/db2/jcc/11.5.0.0/jcc-11.5.0.0.jar">JDBC driver for Db2</a> from Maven Central, and extract the downloaded driver file to the directory that contains the Debezium Db2 connector JAR file (that is, <code>debezium-connector-db2-3.0.5.Final.jar</code>).</p> | ||
| <div class="admonitionblock important"> | ||
| <table> | ||
| <tr> | ||
|
|
@@ -5680,9 +5680,28 @@ <h4 id="db2-advanced-configuration-properties"><a class="anchor" href="#db2-adva | |
| <p><code>t</code></p> | ||
| </div></div></td> | ||
| <td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph"> | ||
| <p>A comma-separated list of operation types that will be skipped during streaming. | ||
| The operations include: <code>c</code> for inserts/create, <code>u</code> for updates, <code>d</code> for deletes, <code>t</code> for truncates, and <code>none</code> to not skip any operations. | ||
| By default, truncate operations are skipped (not emitted by this connector).</p> | ||
| <p>A comma-separated list of the operation types that you want the connector to skip during streaming. | ||
| You can configure the connector to skip the following types of operations:</p> | ||
| </div> | ||
| <div class="ulist"> | ||
| <ul> | ||
| <li> | ||
| <p><code>c</code> (insert/create)</p> | ||
| </li> | ||
| <li> | ||
| <p><code>u</code> (update)</p> | ||
| </li> | ||
| <li> | ||
| <p><code>d</code> (delete)</p> | ||
| </li> | ||
| <li> | ||
| <p><code>t</code> (truncate)</p> | ||
| </li> | ||
| </ul> | ||
| </div> | ||
| <div class="paragraph"> | ||
| <p>Set the value to <code>none</code> if you do not want the connector to skip any operations. | ||
| Because the Debezium Db2 connector does not support <code>truncate</code> change events, setting the default <code>t</code> value has the same effect as setting the value to <code>none</code>.</p> | ||
| </div></div></td> | ||
| </tr> | ||
| <tr> | ||
|
|
@@ -6238,36 +6257,6 @@ <h5 id="debezium-db2-connector-pass-through-kafka-signals-configuration-properti | |
| <p>An integer value that specifies the maximum number of milliseconds that the connector waits when polling signals.</p> | ||
| </div></div></td> | ||
| </tr> | ||
| <tr> | ||
| <td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph"> | ||
| <p><a id="db2-kafka-consumer-offset-commit-enabled"></a><a href="#db2-kafka-consumer-offset-commit-enabled"><code>kafka.consumer.offset.commit.enabled</code></a></p> | ||
| </div></div></td> | ||
| <td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph"> | ||
| <p><code>false</code></p> | ||
| </div></div></td> | ||
| <td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph"> | ||
| <p>Specifies whether the Kafka consumer writes an offset commit after it reads a message from the signaling topic. | ||
| The value that you assign to this property determines whether the connector can process requests that the signaling topic receives while the connector is offline. | ||
| Choose one of the following settings:</p> | ||
| </div> | ||
| <div class="dlist"> | ||
| <dl> | ||
| <dt class="hdlist1"><code>false</code></dt> | ||
| <dd> | ||
| <p>When the connector is unavailable, the Kafka consumer does not commit an offset after it reads a signal received by the signaling topic. | ||
| As a result, if the connector is offline for any interval, it cannot process requests that the signaling topic receives during the downtime. | ||
| After the connector restarts, it always reads from the last position in the Kafka signaling topic, processing only signals that it receives after the restart. | ||
| Signals received while the connector is offline are ignored, and are effectively lost.</p> | ||
| </dd> | ||
| <dt class="hdlist1"><code>true</code></dt> | ||
| <dd> | ||
| <p>When a user submits a request to the signaling topic, after the Kafka consumer reads the signal message it commits a topic offset, even if the connector is offline. | ||
| Choose this option to provide Debezium with information about the last signal message that the consumer read, helping to ensure At-Least-Once delivery. | ||
| After a connector restarts, it resumes processing from the last recorded offset, responding to signals that users submitted while the connector is offline.</p> | ||
| </dd> | ||
| </dl> | ||
| </div></div></td> | ||
| </tr> | ||
| </tbody> | ||
| </table> | ||
| </div> | ||
|
|
@@ -7297,7 +7286,7 @@ <h3 id="db2-hot-schema-update"><a class="anchor" href="#db2-hot-schema-update">< | |
|
|
||
| <div id="toc-rightbar"></div> <footer class="footer"> | ||
| <div class="wrapper"> | ||
| <div class="copyright">Copyright © 2024 Debezium Community (Rev: <span class="truncated"><a href="https://github.com/debezium/debezium/commit/066a74cbf8b9ee8fe7a77d6e1c3af2610ae4c9ca">066a74cb</a></span>) | ||
| <div class="copyright">Copyright © 2024 Debezium Community (Rev: <span class="truncated"><a href="https://github.com/debezium/debezium/commit/7263818a4bf8fbc03a272d8df6ca58fbf58d1e33">7263818a</a></span>) | ||
|
|
||
| </div> | ||
| </footer> | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.