Failed to prepare statement: Invalid config variable(s) in the WITH clause: KEY

ksqlDB
1

Hi, I am new to KSQLDB queries. I tried the following query and ran into error “Failed to prepare statement: Invalid config variable(s) in the WITH clause: KEY”. What am I doing wrong?
CREATE STREAM claims_filtered
( sbm_rx_nbr VARCHAR,
clm_stts VARCHAR,
carrier_id VARCHAR,
account_id VARCHAR,
group_id VARCHAR,
member_id VARCHAR,
sbm_prescriber_id VARCHAR,
carrier_nm VARCHAR,
Claim_type VARCHAR,
prd_desc VARCHAR,
rej_reject_cde_1 VARCHAR,
rej_reject_cde_1_desc VARCHAR,
stlmnt_cde_1 DOUBLE,
stlmnt_cde_1_msg VARCHAR,
dt_submitted DOUBLE)
WITH (KAFKA_TOPIC=‘claims’,
VALUE_FORMAT=‘JSON’,
KEY=‘sbm_rx_nbr’);

Thanks for your help,
Krishna

2

It worked with the following change. I removed KEY from WITH clause and added to the column name as below:
CREATE STREAM claims_filtered
( sbm_rx_nbr VARCHAR KEY,
clm_stts VARCHAR,
carrier_id VARCHAR,
account_id VARCHAR,
group_id VARCHAR,
member_id VARCHAR,
sbm_prescriber_id VARCHAR,
carrier_nm VARCHAR,
Claim_type VARCHAR,
prd_desc VARCHAR,
rej_reject_cde_1 VARCHAR,
rej_reject_cde_1_desc VARCHAR,
stlmnt_cde_1 DOUBLE,
stlmnt_cde_1_msg VARCHAR,
dt_submitted DOUBLE)
WITH (KAFKA_TOPIC=‘claims’,
VALUE_FORMAT=‘JSON’
);

3

This topic was automatically closed after 30 days. New replies are no longer allowed.