Featured Posts
- Online machine learning with the data streams from the database
- Debezium signaling and notifications - Part 2: Customisation
- Debezium signaling and notifications - Part 1
- Image classification with Debezium and TensorFlow
- Streaming Vitess at Bolt
- Distributed Data for Microservices — Event Sourcing vs. Change Data Capture
- Building Audit Logs with Change Data Capture and Stream Processing
- Streaming Cassandra at WePay - Part 1
- Reliable Microservices Data Exchange With the Outbox Pattern
- Automating Cache Invalidation With Change Data Capture
- Materializing Aggregate Views With Hibernate and Debezium
- Five Advantages of Log-Based Change Data Capture
- Creating DDD aggregates with Debezium and Kafka Streams
- Streaming Data Changes from Your Database to Elasticsearch
Tags
apache kafka apache kafka apicurio avro aws caassandra camel cassandra cdc channels community community stories containers cqrs custom datalake db2 ddd debezium debezium server debezium ui deduplication discussion docker elasticsearch event sourcing exactly once semantics example examples features fedora flink hiring iceberg integration introduction jaeger json kafka kafka streams kafka streams kogito ksql kubernetes lakehouse machine learning microservices mongo mongodb mysql news newsletter notifications online learning oracle outbox postgres presentation production quarkus questdb rds releases schema scylla secrets sentry serialization signaling smt snapshots spanner spark sql sqlserver tensorflow testcontainers tests time series topics tracing transactions vagrant vitess website
Debezium Blog
In this post, we are going to talk about a CDC-CQRS pipeline between a normalized relational database, MySQL, as the command database and a de-normalized NoSQL database, MongoDB, as the query database resulting in the creation of DDD Aggregates via Debezium & Kafka-Streams.
