New features:
- Adds opt-in support for the Storage Write API, which can be enabled via the
useStorageWriteApi
property. If enabled, the default stream will be used, unless theenableBatchMode
property is set totrue
, in which case, the pending type stream will be used instead. NOTE: This is currently a beta feature and is not recommended for use in production.
Bug fixes:
- Permits multiple topics to be routed to the same table with the
topic2TableMap
property (confluentinc/kafka-connect-bigquery#361) - Adds retry logic for "jobInternalError" errors when performing merge queries in upsert/delete mode (confluentinc/kafka-connect-bigquery#363)