How to modify kafka topic replication factor that is created by mongodb connector

alaa_halawani · 2020-09-28T22:58:09.634Z

HI,
I am using mongodb kafka connector as source connector. I am not sure how to increase the replication factor of the created topic.
I tried adding these configs:

“confluent.topic.replication.factor” : "3
CONNECT_CONFLUENT_TOPIC_REPLICATION_FACTOR=3
but non of them changed the replication factor.
Is there any specific config from mongo connector itself ?

Robert_Walters · 2020-09-29T12:51:09.817Z

Are you trying to set topic replication factor for kafka connect service itself or override the value just for the MongoDB source connector?

alaa_halawani · 2020-09-29T13:29:33.611Z

Thanks for replying @Robert_Walters.

both are ok for me as I am using mongo connector only with kafka connect service.
I tried passing this “confluent.topic.replication.factor” : “3” as part of mongo connector config and i also tried passing environment variable for kafka connect service and in both ways the replication factor in kafka hasn’t changed.

Could you please guide me how to do that either from kafka connect service or MongoDB source connector ?

valeeum · 2022-10-01T00:59:55.998Z

I’m interested in the answer to this too. I think the op is trying to figure out how to set the replication factor for topics that are auto-created by the mongodb source connector.

Hitesh_Musale · 2024-08-13T07:47:31.760Z

This worked for me :
“topic.creation.enable”: “true”,
“topic.creation.default.replication.factor”: 3,