Confluent 2026年4月17日のリリースノート解説: BigQuery Sink V2 が String input format に対応

Confluent Cloud の 2026年4月17日更新では、BigQuery Sink V2 connector が String input format に対応しました。Kafka から BigQuery へ流すデータ形式の選択肢が広がる更新です。

要点

• BigQuery Sink V2 connector が String input format をサポート
• JSON / Avro / Protobuf 以外の文字列 payload を扱いやすくなる
• 既存 topic の形式を大きく変えずに BigQuery 連携できる可能性がある
• schema 管理、変換、エラー処理の設計は引き続き確認が必要

今回の更新で何が変わるのか

BigQuery への sink connector は、イベントデータを分析基盤へ届ける定番の経路です。String input format 対応により、文字列 payload をそのまま扱う既存 Kafka topic でも BigQuery 連携を検討しやすくなります。

一方、BigQuery 側で分析しやすい形にするには、文字列のまま保存するのか、変換して構造化するのかを決める必要があります。

対象になりそうなチーム

• Kafka から BigQuery へデータを流している data platform team
• 既存 topic が String payload を使っている組織
• connector の移行や V2 化を検討しているチーム
• ストリーミングデータを BigQuery 分析へつなげたい analytics team

実務でまず確認したいこと

1. 対象 topic の payload 形式と BigQuery 側の保存形式を確認する
2. String payload の parse / validation / dead-letter 処理を設計する
3. 既存 BigQuery Sink から V2 へ移行する場合の差分を検証する

結局、この更新をどう見るべきか

BigQuery Sink V2 の String 対応は、地味ですが既存 Kafka 資産を BigQuery に接続しやすくする改善です。データ形式の制約で連携を後回しにしていたチームには確認価値があります。