Skip to content

Instantly share code, notes, and snippets.

@Mcdavid95

Mcdavid95/MongoSourceConnector.properties

Created May 24, 2020 18:47
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save Mcdavid95/addfad63843511534e3a52da84887e1f to your computer and use it in GitHub Desktop.
Save Mcdavid95/addfad63843511534e3a52da84887e1f to your computer and use it in GitHub Desktop.
Download ZIP
Raw
MongoSourceConnector.properties
name=mongo-source
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
tasks.max=1
# Connection and source configuration
connection.uri=mongodb+srv://dbUser:dbUserPassword@cluster0-jj6uu.mongodb.net/test?retryWrites=true&w=majority
database=sample_airbnb
collection=
topic.prefix=mongo
poll.max.batch.size=1000
poll.await.time.ms=5000
# Change stream options
pipeline=[{"$match": { "$or": [{"operationType": "insert"},{"operationType": "update"}]}}]
batch.size=0
change.stream.full.document=updateLookup
publish.full.document.only=true
collation=
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment