danny0405 commented on a change in pull request #14151:
URL: https://github.com/apache/flink/pull/14151#discussion_r527564008
##########
File path: docs/dev/table/connectors/formats/debezium.md
##########
@@ -154,6 +162,50 @@ SELECT * FROM topic_products;
Format Options
----------------
+Flink provides `debezium-avro-confluent` and `debezium-json` formats to
interpret Avro or Json messages produced by Debezium.
+Please pick corresponding format according to your Debezium message encoding.
+
Review comment:
Use format `debezium-avro-confluent` to interpret Debezium Avro messages
and format `debezium-json` to interpret Debezium Json messages.
##########
File path: docs/dev/table/connectors/formats/debezium.md
##########
@@ -99,7 +107,7 @@ CREATE TABLE topic_products (
'topic' = 'products_binlog',
'properties.bootstrap.servers' = 'localhost:9092',
'properties.group.id' = 'testGroup',
- 'format' = 'debezium-json' -- using debezium-json as the format
+ 'format' = 'debezium-json' -- please use 'debezium-avro-confluent' if
Debezium encodes messages in Avro format
)
Review comment:
We better keep the original comment and add a new TAB for avro here.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
