simply what i want is i have two collections in an mongo uri and i want to transfer it into anither mongo uri here are my properties files below
source-1.properties:
name=source1-connector
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
tasks.max=1
connection.uri=mongodb://localhost:5000
database=ax
collection=test
topic.prefix=source1-
startup.mode=copy_existing
source-2.properties:
name=source2-connector
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
tasks.max=1
connection.uri=mongodb://localhost:5000
database=ax2
collection=test2
topic.prefix=source2-
startup.mode=copy_existing
sink1.properties:
name=sink1-connector
connector.class=com.mongodb.kafka.connect.MongoSinkConnector
tasks.max=1
topics=source1-sink1
connection.uri=mongodb://localhost:5000
database=appviewx
collection=sink
max.num.retries=3
retries.defer.timeout=5000
field.renamer.mapping=
field.renamer.regex=
max.batch.size = 0
rate.limiting.timeout=0
rate.limiting.every.n=0
sink2.properties:
name=sink2-connector
connector.class=com.mongodb.kafka.connect.MongoSinkConnector
tasks.max=1
topics=source2-sink2
connection.uri=mongodb://localhost:5000
database=ap2
collection=sink2
max.num.retries=3
retries.defer.timeout=5000
field.renamer.mapping=
field.renamer.regex=
max.batch.size = 0
rate.limiting.timeout=0
rate.limiting.every.n=0