search

lensesio / stream-reactor

A collection of open source Apache 2.0 Kafka Connector maintained by Lenses.io.
https://lenses.io
Apache License 2.0
1.01k stars 366 forks source link

MQTT source - possibility to pass default number of partition a replication factor #1361

Open dberardo-com opened 2 months ago

dberardo-com commented 2 months ago

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/

andrewstevenson commented 2 months ago

@dberardo-com These are Connect Framework settings and not for the connector plugin to implement. Are you running Kafka 2.6 or above?

dberardo-com commented 1 month ago

kafka 3.x with KRAFT i find the kafka doc very hard to follow when it comes to kafka connect.

which parameters are those which are natively supported?