CREATE STREAM AS SELECT is not exists KEY property about ksql

[FrankR85]

Your tutorials still show the old syntax

[arruw]

I'm having the same issue on version 6.0.0

sh-4.4$ ksql
OpenJDK 64-Bit Server VM warning: Option UseConcMarkSweepGC was deprecated in version 9.0 and will likely be removed in a future release.

                  ===========================================
                  =       _              _ ____  ____       =
                  =      | | _____  __ _| |  _ \| __ )      =
                  =      | |/ / __|/ _` | | | | |  _ \      =
                  =      |   <\__ \ (_| | | |_| | |_) |     =
                  =      |_|\_\___/\__, |_|____/|____/      =
                  =                   |_|                   =
                  =  Event Streaming Database purpose-built =
                  =        for stream processing apps       =
                  ===========================================

Copyright 2017-2020 Confluent Inc.

CLI v6.0.0, Server v6.0.0 located at http://localhost:8088

Having trouble? Type 'help' (case-insensitive) for a rundown of how things work!

ksql> CREATE TABLE itemsTable WITH(KAFKA_TOPIC='coreCmdItemV2', VALUE_FORMAT='avro', KEY='ID');
Failed to prepare statement: Invalid config variable(s) in the WITH clause: KEY
ksql>

[agavra]

hello @matjazmav - we removed the WITH(key= syntax in 6.0. You can read more about it here: https://www.confluent.io/blog/ksqldb-0-10-updates-key-columns/

the tl;dr is that you should specify the key in your create statement: CREATE TABLE itemsTable (ID INT PRIMARY KEY) WITH(...);

[zhuxt2015]

then I meet another issue ，when I replaced KEY with PARTITION_BY and execute the create stream statement again,

ksql> CREATE STREAM test_timestamp2  WITH (kafka_topic='test_time',partition_by='genTime',partitions=3,replications=3,timestamp='genTime') as select flag,id,username,money,stringtotimestamp(create_time,'yyyy-MM-dd HH:mm:ss') as genTime, random from test1;
io.confluent.ksql.util.KsqlException: Cannot add the new topic. Another topic with the same name already exists: test_time
ksql> show topics;

 Kafka Topic    | Registered | Partitions | Partition Replicas 
---------------------------------------------------------------
 ksql__commands | true       | 1          | 1                  
 live           | true       | 3          | 3                  
 test           | false      | 1          | 1                  
 test_time      | true       | 3          | 3                  
 TEST_TIMESTAMP | false      | 3          | 3
ksql> list streams;

 Stream Name    | Kafka Topic | Format    
------------------------------------------
 TEST_TIMESTAMP | test_time   | DELIMITED 
 TEST1          | live        | DELIMITED 

The topic test_time already created even though the statement failure.

[hjafarpour]

@zhuxt2015 Thanks for your feedback. The docs issue has been resolved. The first statement you ran created the result topic. You need to delete this topic in Kakfka or use a different topic name for the result stream.
Let us know if you find any other issues.

[sgulati89]

Hi Team,

Is it still not fixed? I am using 5.0 version of confluent and I am still getting error " Invalid config variable in the WITH clause: KEY"

[gpinu1]

Is this fixed in confluent version 5.2.1?

I am getting the same error with the confluent 5.2.1

[agavra]

@FrankR85 - you linked to the 5.4 versions of the docs, please try the newest versions which link to the microsite (https://docs.ksqldb.io/en/latest/developer-guide/ksqldb-reference/create-table-as-select/)