Kafka source connector not sending delete record to kafka topic

When publish.full.document enabled, source connector unable to push delete record(full document as NULL) to kafka topic, as a result sink is unable to handle delete requests from source.

Could you suggest if this is an expected behavior. Or is there any specific config we are missing?

publish.full.document is enabled as we need complete document for each update operation.

1 Like


Yes this is the known issue (sorry feature of MongoDB connector) done by design at least per Documentation.

I suggest you to open another connector that will receive deletes e.g. configured to receive only changes - not full documents.