[
https://issues.apache.org/jira/browse/FLINK-20313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238796#comment-17238796
]
Jark Wu commented on FLINK-20313:
---------------------------------
Environemnt:
- MySQL: docker, v5.7
- Debezium: docker, v1.13
- Kafka: docker, v2.6.0
- Elasticsearch: docker. v7.6
3 tables (orders, products, shipments) in MySQL, capture changes by Debezium
into Kafka topics.
All the 3 topics are read using "kafka" connector + "debezium-avro-confluent"
format.
Cases:
1. Read "orders" topic, check result when updating MySQL tables. **pass**
2. Join 3 tables into Elasticsearch, check result when updating MySQL tables.
**pass**
3. Group aggregate on "orders" topic, write into upsert-kafka with
"avro-confluent" and "raw" format, check result in SQL CLI when updating MysQL
tables . **pass**
4. Using {{kafka-avro-console-consumer.sh}} to view the upsert kafka topic. It
only works when key and value are both using "avro-confluent". The upsert
results are as expected. **pass**
> Test the debezium-avro-confluent format
> ---------------------------------------
>
> Key: FLINK-20313
> URL: https://issues.apache.org/jira/browse/FLINK-20313
> Project: Flink
> Issue Type: Sub-task
> Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table
> SQL / Ecosystem
> Reporter: Jark Wu
> Assignee: Jark Wu
> Priority: Major
> Fix For: 1.12.0
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
