Hi Guys,
We have mongoDB version 4.4. debezium version 2.
We would like to move all our clients from this cluster to a new cluster version 7, using debezium – kafka – and consume it in the target cluster.
We encounter an issue with mongoDB4.4.
The events doesn’t get into the Q, we have no errors in the kafka logs.
We suspect that this is the user permissions issue.
According to debezium documentation:
Link : Debezium connector for MongoDB :: Debezium Documentation
You must also have a MongoDB user that has the appropriate roles to read the `admin` database where the oplog can be read. Additionally, the user must also be able to read the `config` database in the configuration server of a sharded cluster and must have `listDatabases` privilege action. When change streams are used (the default) the user also must have cluster-wide privilege actions `find` and `changeStream`.
When you intend to utilize pre-image and populate the `before` field, you need to first enable `changeStreamPreAndPostImages` for a collection using `db.createCollection()`, `create`, or `collMod`.
Which privileges I should grant him i don’t find in the documentation changeStreamPreAndPostImages option and listDatabases option.
I provided it root permissions and still we have the same issue
db.createUser({
user: "dbz", pwd: "dbz", roles:
[ { role: "root", db: "admin" } ]});
Can you please advise ?