Mark Storage Write API feature as beta

Aiven-Open · Mar 27, 2024 · 4a43dbf · 4a43dbf
1 parent 1a2684a
commit 4a43dbf
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/docs/sink-connector-config-options.rst b/docs/sink-connector-config-options.rst
@@ -154,7 +154,7 @@ BigQuery Sink Connector Configuration Options
   * Importance: medium
 
 ``useStorageWriteApi``
-  Use Google's New Storage Write API for data streaming. Not available for upsert/delete mode
+  (Beta feature: use with caution) Use Google's New Storage Write API for data streaming. Not available for upsert/delete mode
 
   * Type: boolean
   * Default: false
@@ -187,7 +187,7 @@ BigQuery Sink Connector Configuration Options
 
   * Type: list
   * Default: null
-  * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000d8014d0440@325a48a1
+  * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000f001235108@5d9f3e38
   * Importance: low
 
 ``commitInterval``
@@ -273,7 +273,7 @@ BigQuery Sink Connector Configuration Options
 
   * Type: long
   * Default: null
-  * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000d8014d0890@7f1de728
+  * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000f001235558@16147134
   * Importance: low
 
 ``timestampPartitionFieldName``
@@ -289,7 +289,7 @@ BigQuery Sink Connector Configuration Options
 
   * Type: string
   * Default: ""
-  * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000d8014cf200@7dad73ea
+  * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000f001234000@69a3b76d
   * Importance: low
 
 ``upsertEnabled``
@@ -324,7 +324,7 @@ Common
 
   * Type: string
   * Default: DAY
-  * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000d8014d75e8@4065faf5
+  * Valid Values: com.wepay.kafka.connect.bigquery.config.BigQuerySinkConfig$$Lambda/0x000000f001239e90@356a0fbe
   * Importance: low
 
 
diff --git a/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java b/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/config/BigQuerySinkConfig.java
@@ -340,7 +340,7 @@ public class BigQuerySinkConfig extends AbstractConfig {
   private static final ConfigDef.Type USE_STORAGE_WRITE_API_TYPE = ConfigDef.Type.BOOLEAN;
   private static final ConfigDef.Importance USE_STORAGE_WRITE_API_IMPORTANCE = ConfigDef.Importance.MEDIUM;
   private static final String USE_STORAGE_WRITE_API_DOC =
-      "Use Google's New Storage Write API for data streaming. Not available for upsert/delete mode";
+      "(Beta feature: use with caution) Use Google's New Storage Write API for data streaming. Not available for upsert/delete mode";
   private static final ConfigDef.Type ENABLE_BATCH_MODE_TYPE = ConfigDef.Type.BOOLEAN;
   private static final ConfigDef.Importance ENABLE_BATCH_MODE_IMPORTANCE = ConfigDef.Importance.LOW;
   private static final String ENABLE_BATCH_MODE_DOC = "Use Google's New Storage Write API with batch mode";