搜索结果
查询Tags标签： Debezium，共有 9条记录-
debezium 之六 安装wal2json
规划 192.168.56.11 k1 192.168.56.12 k2 192.168.56.13 k3 192.168.56.21 pg11n1 192.168.56.22 pg11n2主机 pg11n1 、pg11n2上安装好 postgresql 11 后，需要安装 postgres-decoderbufs debezium 需要插件 decoderbufs 或者 wal2json ，或者 pgoutput。 安装 wal2j…
2021/11/16 23:13:45 人评论 次浏览 -
debezium 之六 安装wal2json
规划 192.168.56.11 k1 192.168.56.12 k2 192.168.56.13 k3 192.168.56.21 pg11n1 192.168.56.22 pg11n2主机 pg11n1 、pg11n2上安装好 postgresql 11 后，需要安装 postgres-decoderbufs debezium 需要插件 decoderbufs 或者 wal2json ，或者 pgoutput。 安装 wal2j…
2021/11/16 23:13:45 人评论 次浏览 -
Debezium 实时同步数据库
Debezium 是一个 CDC（Changelog Data Capture，变更数据捕获）的工具，可以把来自 MySQL、PostgreSQL、Oracle、Microsoft SQL Server 和许多其他数据库的更改实时流式传输到 Kafka 中。 Debezium 为变更日志提供了统一的格式结构，并支持使用 JSON 和 Apache Avro 序列化…
2021/6/6 19:27:01 人评论 次浏览 -
聊聊debezium的ElapsedTimeStrategy
序 本文主要研究一下debezium的ElapsedTimeStrategy ElapsedTimeStrategy debezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/util/ElapsedTimeStrategy.java @FunctionalInterface public interface ElapsedTimeStrategy {/*** Determine if the time peri…
2020/5/24 17:27:27 人评论 次浏览 -
聊聊debezium的RecordMakers
序 本文主要研究一下debezium的RecordMakers RecordMakers debezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/RecordMakers.java public class RecordMakers {private final Logger logger = LoggerFactory.getLogger(getClass…
2020/5/21 17:27:09 人评论 次浏览 -
聊聊debezium的eventHandlers
序 本文主要研究一下debezium的eventHandlers handleInsert debezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.java public class BinlogReader extends AbstractReader {//......protected void handleInsert(Ev…
2020/5/20 17:27:27 人评论 次浏览 -
聊聊DebeziumEngine
序 本文主要研究一下DebeziumEngine DebeziumEngine debezium-v1.1.1.Final/debezium-api/src/main/java/io/debezium/engine/DebeziumEngine.java @Incubating public interface DebeziumEngine<R> extends Runnable, Closeable {//......public static <T> …
2020/5/17 17:26:47 人评论 次浏览 -
聊聊debezium的BlockingReader
序 本文主要研究一下debezium的BlockingReader Reader debezium-v1.1.1.Final/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/Reader.java public interface Reader {public static enum State {/*** The reader is stopped and static.*/STOPPED,…
2020/5/17 17:26:45 人评论 次浏览 -
聊聊debezium的ChangeEventQueue
序 本文主要研究一下debezium的ChangeEventQueue ChangeEventQueueMetrics debezium-v1.1.1.Final/debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueueMetrics.java public interface ChangeEventQueueMetrics {int totalCapacity();int remaining…
2020/5/13 17:25:54 人评论 次浏览
