Ingest events into Pub/Sub to stream to BigQuery, data lakes and databases; messaging middleware for streaming analytics and service integrations