File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
source/includes/fundamentals/cdc Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -25,7 +25,12 @@ CDC events from each of the preceding datastores:
25
25
database=<your mongodb database>
26
26
collection=<your mongodb collection>
27
27
topics=<topic containing debezium cdc events>
28
- change.data.capture.handler=com.mongodb.kafka.connect.sink.cdc.debezium.mongodb.MongoDbHandler
28
+ change.data.capture.handler=com.mongodb.kafka.connect.sink.cdc.debezium.mongodb.ChangeStreamHandler
29
+
30
+ .. note ::
31
+
32
+ If you are using a Debezium CDC version earlier than 2.0, set the value of the
33
+ ``change.data.capture.handler `` property to ``com.mongodb.kafka.connect.sink.cdc.debezium.mongodb.MongoDbHandler ``.
29
34
30
35
To view the source code for the Debezium CDC handler, see
31
36
:github: `the {+connector+} source code </mongodb/mongo-kafka/tree/{+connector_version_github_tag+}/src/main/java/com/mongodb/kafka/connect/sink/cdc/debezium> `.
You can’t perform that action at this time.
0 commit comments