search

hpgrahsl / kafka-connect-mongodb

**Unofficial / Community** Kafka Connect MongoDB Sink Connector -> integrated 2019 into the official MongoDB Kafka Connector here: https://www.mongodb.com/kafka-connector
Apache License 2.0
153 stars 60 forks source link

Can I customize Kafka topic from MongoSourceConnector? #130

Closed HyunSangHan closed 2 years ago

HyunSangHan commented 2 years ago

@hpgrahsl Hi! again. :)

I want to send Kafka messages to one topic from several MongoSourceConnectors. That is, what I want: (MongoSourceConnector : Kafka topic = N : 1)

However, I know that Kafka messages from MongoSourceConnector are created automatically like {prefix}.{dbName}.{collectionName}, so it seems to be MongoSourceConnector : Kafka topic = 1 : 1 relation.

(ref: https://docs.mongodb.com/kafka-connector/current/kafka-source/#topic-naming-examples)

Can I customize the topic name from each MongoSourceConnector?

HyunSangHan commented 2 years ago

I will close this issue, because I finally resolved it.