The Wayback Machine - https://web.archive.org/web/20200625231523/https://github.com/topics/debezium
Skip to content
#

debezium

Here are 69 public repositories matching this topic...

zachariahyoung
zachariahyoung commented Mar 19, 2020

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

The goal is to play with Debezium and KSQL. For this, we have: research-service that inserts/updates/deletes records in MySQL; Source Connectors that monitor change of records in MySQL and push messages related to those changes to Kafka; Sink Connectors and kafka-research-consumer that read messages from Kafka and insert/update documents in Elasticsearch; finally, KSQL-Server that listens some topics in Kafka, does some joins and pushes new messages to new topics in Kafka.

  • Updated Jun 9, 2020
  • Java

Improve this page

Add a description, image, and links to the debezium topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the debezium topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.