Click here to Skip to main content
15,744,193 members
Please Sign up or sign in to vote.
1.00/5 (1 vote)
I am using Cassandra Sink Connector with Kafka, now i want to insert whole topic JSON as it is into single Cassandra table column instead of creating diff cols. so what should be the connector KCQL expression ?

INSERT INTO connector_json_table SELECT * FROM test-nk-29-dec

Topic name : test-nk-29-dec
Cassandra Table name with only one column - connector_json_table

connector_json_table contains only one single column with "Text type", Now i want to insert complete JSON into this col.

What I have tried:

<pre>INSERT INTO connector_json_table SELECT * FROM test-nk-29-dec
Updated 30-Dec-20 17:50pm

This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

CodeProject, 20 Bay Street, 11th Floor Toronto, Ontario, Canada M5J 2N8 +1 (416) 849-8900