-
Added support for
Upsert
operation in Postgres, Clickhouse isn't supported right now. -
Improved batch block flush logic to flush after a certain number of blocks instead of taking by modulo.
-
Fixed cursor loading on Clickhouse.
-
Fixed a bug with not flushing rows on stream completion.
-
Added
--clickhouse-cluster
flag. If non-empty the sink will apply aON CLUSTER <cluster>
clause when setting up tables and replace table engines with theirReplicated
counterparts. -
Added flushed block number and time drift metrics.