moggaa commented on code in PR #17653:
URL: https://github.com/apache/iceberg/pull/17653#discussion_r4121994441
##########
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/IcebergSinkConfig.java:
##########
@@ -179,6 +181,12 @@ private static ConfigDef newConfigDef() {
false,
Importance.MEDIUM,
"Set to true to add any missing record fields to the table schema,
false otherwise");
+ configDef.define(
+ TABLES_REPLACE_NULL_WITH_DEFAULT_PROP,
+ ConfigDef.Type.BOOLEAN,
+ true,
+ Importance.MEDIUM,
+ "Set to false to preserve explicit null values instead of replacing
them with the record schema default value, true otherwise");
Review Comment:
Applied in d585a0d49, and aligned the docs table row to the same true-first
phrasing.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
