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 {