0

I am trying to follow this tutorial to make a ksqldb stream using avro (https://rmoff.net/2021/03/12/kafka-connect-jdbc-sink-deep-dive-working-with-primary-keys/). I try the first command:

CREATE STREAM FOO_01 (COL1 INT, COL2 INT)
WITH (KAFKA_TOPIC='FOO_01', VALUE_FORMAT='AVRO', PARTITIONS=1);

but keep getting this error: enter image description here

I have tried doing the command with json instead of avro and it works fine.

I tried creating a schema in the apicurio schema registry that's being used and manually gave it the name and id of FOO_1-value to match the topic. Same problem. The topic wasn't already created (figured it would be created automatically but realized the json one just makes a stream, not a new kafka topic) so I manually made a kafka topic named FOO_1 from the kafka-topics.sh in the cli and tried the command again. No luck. Same error message.

So I am stumped. And in the tutorial I feel like I am missing some initial set up step. But I don't event know where a "detail" field and the schemaregistry code is at. Everything is pretty out of the box and no custom error handling logic has been made (or any custom code in files since I am just trying to do a tutorial).

Any ideas?

Jicaar
  • 1,044
  • 10
  • 26
  • 1
    1) I believe "detail" is a response field from the **Confluent** registry server. I don't think ksql officially supports Apicurio's registry. In any case, you may want to upgrade to a newer KSQL/CLI version, as something may have changed 2) `JSON` doesn't use the Registry, so yes, that will work just fine. `JSON_SR` probably will also fail, however – OneCricketeer Mar 28 '23 at 22:20

0 Answers0