MongoSinkConnector.properties

name=mongo-sink
topics=mongo.sample_airbnb.listingsAndReviews
connector.class=com.mongodb.kafka.connect.MongoSinkConnector
tasks.max=1

# Message types
key.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true

value.converter=org.apache.kafka.connect.json.JsonConverter
value.converter.schemas.enable=true

key.converter.schema.registry.url=http://localhost:8081
value.converter.schema.registry.url=http://localhost:8081

# Specific global MongoDB Sink Connector configuration
connection.uri=mongodb+srv://dbUser:dbUserPassword@cluster0-kppha.mongodb.net/test?retryWrites=true&w=majority
database=sample_airbnb
collection=listingsAndReviews
max.num.retries=2147483647
retries.defer.timeout=5000


## Document manipulation settings
key.projection.type=none
key.projection.list=_id
value.projection.type=none
value.projection.list=_id

field.renamer.mapping=[]
field.renamer.regex=[]

document.id.strategy=com.mongodb.kafka.connect.sink.processor.id.strategy.ProvidedInValueStrategy
post.processor.chain=com.mongodb.kafka.connect.sink.processor.DocumentIdAdder


# Write configuration
delete.on.null.values=false
writemodel.strategy=com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneDefaultStrategy

max.batch.size = 0
rate.limiting.timeout=0
rate.limiting.every.n=0

# Change Data Capture handling
change.data.capture.handler=
# com.mongodb.kafka.connect.sink.cdc.debezium.mongodb.MongoDbHandler

# Topic override examples for the sourceB topic
topic.override.sourceB.collection=sourceB