File tree Expand file tree Collapse file tree 2 files changed +29
-0
lines changed
Expand file tree Collapse file tree 2 files changed +29
-0
lines changed Original file line number Diff line number Diff line change 1+ ## State Storage
2+
3+ Sink connector is designed to store data about the replication state.
4+ Currently the only supported state storage is by persisting the information in ClickHouse tables.
5+
6+ ### ClickHouse State Storage
7+
8+ To use ClickHouse as a state storage, you need to specify the following configuration properties:
9+
10+ state storage link to img/state_storage.png
11+
12+
13+
14+
15+
16+ # Offsets table.(PostgreSQL)
17+ | Column Name | Description |
18+ | -------------| ----------------------------------------------------------------------|
19+ | id | UUID |
20+ | offset_key | [ \" debezium-embedded-postgres\" ,{\" server\" :\" embeddedconnector\" }] " |
21+ | offset_val | |
22+ | record_insert_seq | |
23+ | record_insert_ts | |
24+
25+ ### offsets_value
26+ - ** lsn_proc** - Last processed LSN
27+ - ** lsn_commit** - Last committed LSN
28+ - ** messageType** - Type of message(INSERT, UPDATE, DELETE)
29+ -
You can’t perform that action at this time.
0 commit comments