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:
2525 database=<your mongodb database>
2626 collection=<your mongodb collection>
2727 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 ``.
2934
3035 To view the source code for the Debezium CDC handler, see
3136 :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