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;…