When using the Kafka Source Connector that watches the deployment but uses a pipeline (with two+ operations), kafka topics are not getting all events.

{
  "name": "testsource",
  "connector.class": "com.mongodb.kafka.connect.MongoSourceConnector",
  "connection.uri": "mongodb://admin:pass@192.168.74.101:27001/?authSource=admin&replicaSet=repl-example&ssl=false",
  "copy.existing": "false",
  "pipeline": "[ { \"$match\": {\"operationType\": \"dropDatabase\", \"operationType\": \"drop\" } } ]"
} 

Step to repro

1) Use the source connector configuration above to watch entire deployment and looks for only dropDatabase and drop events.

2) Create database test, create collection test.testone, insert doc into test.testone. No events are added to kafka topics, which is the correct behavior.

3) drop test database. The change stream will produce drop and dropDatabase events but only dropDatabase is published to test kafka topic (and no drop event is published to test.testone kafka topic.

EXPECTED BEHAVIOR: test.testone kafka topic should also get a drop event published