Sink connector sinks data from Kafka into Clickhouse. The connector is tested with the following converters
-
JsonConverter
-
AvroConverter (Using Apicurio Schema Registry)
-
Currently the connector only supports Insert operations.
-
Deduplication logic to dedupe records from Kafka topic.
-
Exactly once semantics
-
Bulk insert to Clickhouse.
-
Store Kafka metadata Kafka Metadata