Cassandra Sink connector - array to set/map

[abratnap]

Cassandra sink connector - support populating set, map fields.

I have a JSON message which has few array fields. I want to store this in a SET/MAP field in cassandra. This doesn't work with KSQL. Expected behavior is proper fields should be populated.

CREATE TABLE IF NOT EXISTS docstore (
    id              text,
    keywords        set<text>
);

KCQL query is

INSERT INTO docstore SELECT uid as id, keywords as keywords FROM docs

input message is JSON with keywords as array field.

[abratnap]

similar issue here for avro https://github.com/lensesio/stream-reactor/issues/294

[abratnap]

seems like the support for array is required here https://github.com/lensesio/json-sql