Использование непрерывных запросов BigQuery на основе SQL с Confluent позволяет вам передавать данные вашего хранилища в режиме реального времени, отправляя их вниз по потоку для аналитических задач и не только.
confluent.io
Streaming BigQuery Data Into Confluent in Real Time: A Continuous Query Approach
