Open ivanilk opened 1 year ago
A schema is required. Otherwise, it cannot guarantee that any two events have the exact same fields or types
Worth pointing out that Clickhouse has its own Kafka ingest mechanisms. https://clickhouse.com/docs/en/integrations/kafka#choosing-an-option
Hi There, I’m trying to insert my data from a Kafka Topic into clickhouse with theJDBC Sink Connector. This is my connector config
and this is my message
but got an error
Error: Sink connector 'JdbcSinkConnector_my_topic' is configured with 'delete.enabled=false' and 'pk.mode=record_value' and therefore requires records with a non-null Struct value and non-null Struct schema, but found record at (topic='my_topic',partition=0,offset=0,timestamp=1687020175058) with a HashMap value and null value schema. (org.apache.kafka.connect.runtime.WorkerSinkTask)
Pls help me, thanks all