Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Prepare Glue Schema Registry: https://ap-southeast-1.console.aws.amazon.com/glue/home?region=ap-southeast-1#/v2/data-catalog/schemaRegistries * Registry: "dev" * Schema name: "TemplateEmailEvents" * Version 1 - Version ID 4dc80ccf-2d0c-4846-9325-7e1c9e928121 * Version 3 - Version ID 3df022f4-b16d-4afe-bdf7-cf4baf8d01d3 Prepare Kafka: ``` rpk topic create glue-sample rpk topic produce -f '%v{hex}\n' glue-sample 03004dc80ccf2d0c484693257e1c9e928121.. 03004dc80ccf2d0c484693257e1c9e928121.. 03004dc80ccf2d0c484693257e1c9e928121.. 03004dc80ccf2d0c484693257e1c9e928121.. 03004dc80ccf2d0c484693257e1c9e928121.. 03003df022f4b16d4afebdf7cf4baf8d01d3.. 03003df022f4b16d4afebdf7cf4baf8d01d3.. ``` Run RisingWave: ``` create source t1_forward with ( properties.bootstrap.server='127.0.0.1:51349', connector = 'kafka', topic = 'glue-sample') format plain encode avro ( schema.location = 'file:///tmp/DELME/glue_avsc/TemplateEmailEvents.avsc', with_legacy_file_header = true, region = 'ap-southeast-1', access_key = '', secret_key = '', session_token=''); create source t2_backward with ( properties.bootstrap.server='127.0.0.1:51349', connector = 'kafka', topic = 'glue-sample') format plain encode avro ( schema.location = 'file:///tmp/DELME/glue_avsc/TemplateEmailEventsV2.avsc', with_legacy_file_header = true, region = 'ap-southeast-1', access_key = '', secret_key = '', session_token=''); select * from t1; select * from t2; ```
- Loading branch information