I want to do data migration using the source connector and the sink connector.
The target server’s shard key is not { _id: “hashed” } but { field1: “hashed”, field2: 1, field3: 1, field4: 1}.
However, the sink connector did not work because the shard key was not correct.
As a result of looking up Broker’s messages, it seemed to be producing/consuming data with “_id”.
- Is it right I thought?
- If so, is there a way to make the collection based on _id be collected based on the above shard key?