seems like the mqtt source connector does not take into account: "topic.creation.default.partitions" : "topic.creation.default.replication.factor": https://rmoff.net/2021/01/06/creating-topics-with-kafka-connect/