examples
examples copied to clipboard
Example: Can't created CUSTOMERS_SRC stream
getting the following error message.
ksql> CREATE STREAM CUSTOMERS_SRC WITH (KAFKA_TOPIC='asgard.public.customers', VALUE_FORMAT='AVRO'); Avro schema for message values on topic asgard.public.customers does not exist in the Schema Registry.Subject: asgard.public.customers-value Possible causes include:
I'm following these step by steps https://github.com/confluentinc/examples/blob/latest/postgres-debezium-ksql-elasticsearch/postgres-debezium-ksql-elasticsearch-docker-short.adoc