Changelog

BigQuery connector for Apache Kafka® version 2.7.0

  • Improved
  • Aiven for Apache Kafka® Connect

The BigQuery connector for Apache Kafka has been upgraded to version 2.7.0. This release includes improvements to reliability, configuration flexibility, and Debezium compatibility.

  • Deprecated the GCS-based batch loading feature. This will be removed in a future release.
  • Deprecated the legacy partition decorator syntax. Scheduled for removal in version 3.0.0.
  • Added user-agent and version headers to outgoing requests to improve observability.
  • Improved reliability by retrying getTable() calls with backoff before failure.
  • Added optional support for converting Debezium VariableScaleDecimal types to BigDecimal, preserving precision for PostgreSQL NUMERIC fields.
  • Added a configuration option to extract the GCP project ID from the service account key file, useful in multi-project setups.

For more information, refer to the GitHub release notes for the BigQuery connector for Apache Kafka.