Expand description
MongoDB sink connector implementation.
Implements SinkConnector for writing Arrow RecordBatch data to
MongoDB collections. Supports insert, upsert, and CDC replay
write modes, with optional time series collection support.
Writes are bounded by fixed retained-memory and bulk limits and flushed when
a bound is reached, flush_interval elapses, or shutdown begins.
Keyed and CDC flushes use one ordered MongoDB 8+ bulk operation, preserving
input order without a network round trip per row.
Structsยง
- Mongo
DbSink MongoDBsink connector.