CODEWITHSUNDEEP
apache-kafkaconfluent-platformksqldb
Abhishek D K
Abhishek D K

Reputation: 2427

The key format 'AVRO' is not currently supported

i am following this blog in understanding ElasticSearchSink connector
https://github.com/confluentinc/demo-scene/tree/master/kafka-to-elasticsearch

ksql> CREATE STREAM TEST01 (ALPHA VARCHAR KEY,COL1 INT, COL2 VARCHAR)
       WITH (KAFKA_TOPIC='test01', PARTITIONS=1, FORMAT='AVRO');

got the following error
The key format 'AVRO' is not currently supported.

i am using confluentinc/cp-ksqldb-server:latest and confluentinc/cp-ksqldb-cli:latest

As of Now, replaced FORMAT='AVRO' with VALUE_FORMAT='AVRO'
didn't get any error, can anyone assist if this is the right way to go ?

Upvotes: 0

Views: 539

Answers (1)

OneCricketeer
OneCricketeer

Reputation: 191743

Avro key support is only a recent addition, as of 0.15

If you want to use the latest ksql features, you should be using the confluentinc/ksqldb-server image, which is newer than the "distribution package" cp-ksqldb-server, and what is actually used in that repo

ref https://docs.confluent.io/platform/current/installation/versions-interoperability.html#ksqldb

Upvotes: 1

Related Questions