As the title states, I'm using debezium Postgres source connector and I would like MongoDB sink connector to group kafka topics in different collection and databases (also different dbs to isolate unrelated data) according to their names. While inquiring I…
I'm trying to use Debezium with Kafka connect, I followed this tutorial, and everything connected just fine. However, the problem is that I cannot access Kafka from outside of docker containers anymore. I use these commands to start containers: docker…
I have mongodb and I need to send the changes from a certain query to kafka broker. I heard that debezium tracks changes from database and stores it to kafka. But is there a way to configure that process to…
Debezium server: v 1.9.0.Final MongoDB Atlas: v 4.2.20 Running on AWS ECS with Fargate w/ 1GB CPU & 4GB MEMORY Overview: Debezium starts an initial snapshot and it sends some data to kinesis but it runs into an error (below)…
I am consuming Avro data coming from Debezium I made the kafka consumer as follows: The Java POJO import lombok.Data; @Data public class Shop { Long shopId; Double latitude, longitude; String name; String phoneNumber; String placeId; double rating; String website;…