ivi-ru/flink-clickhouse-sink

How to insert an csv row into a clickhouse db.table?

Closed this issue · 3 comments

I read data from Kafka and transfer data into clickhouse with flink.
And the data is csv row String, the data format on clickhouse is DB.

@JoshuaYin so, let me clarify, you are reading data from kafka and the format is CSV (String), and you want to send these rows to Clickhouse, correct?

Have you tried to implement your own converter, as we have in the example? https://github.com/ivi-ru/flink-clickhouse-sink#in-code

emmmmm,I've resolve the problem with the method like implement my own converter.
Thx~
By the way, the sink is so convenient~

ok, closing this issue