Skip to content

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

@dberardo-com

Description

@dberardo-com

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/

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions