I have set up Kafka cluster and installed confluent-hub on a EC2 instance. I have downloaded the confluent-hub tar file, extracted and placed the binary inside /usr/local/bin. When I am now trying ...

I have an already running production deployed Kafka-Cluster and having Topic "existing-topic". I am using MongoDB-Source-Connector from Debezium. Here all what I want is to push the CDC events di...

I am trying to use MongoDB change stream using Kafka. I chose AWS MSK since my entire infrastructure is within AWS and it will be easy to integrate with other AWS services. I created an AWS MSK clu...

How do I retrieve incoming headers from the kafka message with Kafka Connect to store them as additional data fields with MongoDB Sink Connector to mongodb. I have a kafka topic "PROJECT_EXAMP...

I am new to Kafka and I want to see if I can sync MongoDb data with another system using Kafka. My set up: I am running AWS MSK Cluster and I have created an EC2 instance with Kafka client manuall...

We can update/upsert the record in mongodb BUT is there is any method or function from which we can update or upsert the document directly in mongodb and the source system is kafka and destination ...

I'm using a mongo-source plugin with Kafka-connect. I checked the source task state, and it was running and listening on a mongo collection. I manually stopped mongod service and waited about 1 mi...