src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java [266:275]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                DataTypes.STRING().nullable(),
                new RocketMQRowDataConverter.MetadataConverter() {
                    private static final long serialVersionUID = 1L;

                    @Override
                    public Object read(RowData row, int pos) {
                        if (row.isNullAt(pos)) {
                            return null;
                        }
                        return row.getString(pos).toString();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQDynamicTableSink.java [281:290]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                DataTypes.STRING().nullable(),
                new RocketMQRowDataConverter.MetadataConverter() {
                    private static final long serialVersionUID = 1L;

                    @Override
                    public Object read(RowData row, int pos) {
                        if (row.isNullAt(pos)) {
                            return null;
                        }
                        return row.getString(pos).toString();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -