Click here to Skip to main content
16,016,801 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
Posted
Updated 30-Dec-20 17:50pm
v4

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