Why ClickHouseSinkConnector with Debezium PostgresConnector replicates zero values or nulls #182
-
Hi Guys, My reference docs were mainly: Despite trying many different configs I got to the point where any operation on source Postgres Table produces a row in Clickhouse with 0 or empty values. ClickhouseSinkConnector version: I'm also not sure (docs are actually inconsistent) whether to use My configs (I'm using docker containers with no ssl, dev clickhouse is not exposed at all currently) Postgres connector:
ClickhouseSinkConnector:
Sample message from PostgresTopic (without flattening)
Sample message from PostgresTopic (with flattening)
What could be the reason behind is not replicating correctly Thanks! |
Beta Was this translation helpful? Give feedback.
Replies: 5 comments 17 replies
-
Hmmm, could you attach the "SHOW CREATE TABLE" so I can see the table structure? |
Beta Was this translation helpful? Give feedback.
-
How you're flattening looks right - I think I might know what's going on though. Could you try this for the database?
|
Beta Was this translation helpful? Give feedback.
-
How can I debug the connector plugin ?
|
Beta Was this translation helpful? Give feedback.
-
Ok there's some small breakthrough: After disabling schema it works with
or similar with 'after' So it looks like that sink connector does not interpret Example here clearly confirms that "before" "after" fields feature are meant to be used by forcing |
Beta Was this translation helpful? Give feedback.
-
Hi, i have the same issue , please can you help me ? |
Beta Was this translation helpful? Give feedback.
Hmm, what's interesting is that the first one has null values for before while the second actually fills them in.