Feedback

Retry/reconnect mechanism Mongodb Source Connectors on MongoTimeoutException

The MongoDB Kafka Source and Sink connectors for the data streaming are working fine seamlessly until there are any errors in Kafka Source connectors. If there is any error occurs, the connectors are not recovered from the timeout exceptions and ...

Guest over 2 years ago in Kafka Connector 0 Submitted

3 VOTE

define the random seed manually, for $rand and $sample

It will be great if an additional paramater to define the seed for $rand and $sample could be use.

Guest over 2 years ago in Querying & Aggregations 1 Submitted

3 VOTE

$merge

Report number of docs matched, merged, skipped, etc. from a $merge stage. Alternatively, return the merged doc results as a pipeline result to pass to additional stages.

Charlie Little almost 3 years ago in Querying & Aggregations 0 Submitted

2 VOTE

Make $merge support DELETE operation

Currently, the `$merge` only supports insert/update/upsert/merge behaviour. It would be great to support delete behaviour. A common use case would be in-place document deduplication/clean-up in a collection.

Guest about 2 years ago in Querying & Aggregations 0 Submitted

4 VOTE

Ignore heartbeats-mongodb topic by default

As per KAFKA-208, SMTs can't be applied to the heartbeats-mongodb topic. Users should not have to configure each connector to ignore this topic. Please either ignore this topic by default or provide a command-line switch so it can be ignored.

Guest over 4 years ago in Kafka Connector 0 Submitted

3 VOTE

Document scoped RBAC - Permission for collection document fields

Roles and accesses can be defined on the basis of collections that define roles for users. It would be nice if these access permissions could be made within the scope of the fields under the collection and the query results would be returned accor...

Guest over 3 years ago in Querying & Aggregations 1 Submitted

1 VOTE

Built-in Partial Update $push Strategy for MongoDB Kafka Connector

We would like the official MongoDB Kafka Connector to natively support partial updates that append (\$push) records into an array in an upsert scenario—specifically, a built-in WriteModelStrategy to handle use cases where: We match on a configura...

Guest about 1 year ago in Kafka Connector 0 Submitted

3 VOTE

Support expressions in $densify range bounds

The $densify aggregation pipeline stage seems unable to evaluate range bounds expressions, requiring the range bounds to be constant. See the following example (the collection testcoll contains a single documents with only the _id field): ``` s...

Guest almost 4 years ago in Querying & Aggregations 3 Submitted

4 VOTE

Get schema validation "feedback" in Kafka Mongo Sink Connector

Objective : We want to be able to validate that data matches some requirements. We would like to to perform this data validation by adding a JSON schema in Mongo (such as it is described here : https://docs.mongodb.com/manual/core/schema-validat...

Guest over 5 years ago in Kafka Connector 1 Submitted

4 VOTE

MongoDB Sink Connector CDC default handler

I would like to have a default CDC handler that can process data produced from MongoDB Source Connector without Debezium https://docs.mongodb.com/kafka-connector/master/kafka-sink-cdc#cdc-handler-configuration

Guest over 5 years ago in Kafka Connector 2 Submitted

Please enter your email address

FILTER BY CATEGORY