Ilia

Added a config parameter `auto.create.tables.replicated`

1

Solution for #62. Added a config parameter `auto.create.tables.replicated` that controls replicated tables creation. In this logic I use a separate config parameter `use.replacingmergetree.is_deleted.column` as a flag to manage tables creation....

Fix the getVersionColumnForReplacingMergeTree() to support replicated tables properly

1

1. In the current logic the getVersionColumnForReplacingMergeTree() returns only version_column from a replicated table definition (here `versionColumn = parameterArray[2].trim();`), but a is_deleted column migth be there too. 2. It's unnecessary...

Multiple threads processing

8

I think, that the current code doesn't work properly. I have checked it by logs. It runs ClickhouseBatchRunnable sequently, instead of parallel. We should create a few ClickhouseBatchRunnable tasks by...

Use zoned time when parse string

2

I suggest to use ZonedDateTime instead of LocalDateTime. So we can parse a time_string with an offset marker e.g. +03:00, -0130, Z. Also we can handle an exception when a...

Get last element as a table name from a topic name

3

It would be better if it didn't depend on the hard-coded .. template