From ca009d849281b41af7afee86756e122768714fba Mon Sep 17 00:00:00 2001 From: tjwornjs Date: Mon, 8 Aug 2022 12:34:34 +0900 Subject: [PATCH] DBZ-5489 add column comment to schema --- .../main/java/io/debezium/relational/TableSchemaBuilder.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java b/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java index c40d2bfae..aafd6ae77 100644 --- 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 {