DBZ-5489 add column comment to schema

2022-08-08 12:34:34 +09:00 · 2022-08-08 12:34:34 +09:00 · ca009d8492
commit ca009d8492
parent 2e0a9e8574
1 changed files with 4 additions and 0 deletions
--- a/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java
+++ b/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java
@ -379,6 +379,10 @@ protected void addField(SchemaBuilder builder, Table table, Column column, Colum
                fieldBuilder.optional();
            }

+            if (column.comment() != null) {
+                fieldBuilder.doc(column.comment());
+            }
+
            // if the default value is provided
            if (column.hasDefaultValue() && defaultValue != null) {
                try {