Skip to content
industry-insights
Initializing search
quixio/quix-docs
Quix Docs
quixio/quix-docs
Get started
Get started
Welcome
Get started!
Core concepts
Core concepts
Streaming
Stream processing
Stream processing pipelines
Quix Streams
Quix Streams
Introduction
Quickstart
Tutorials
Tutorials
Word Count
Anomaly Detection
Purchase Filtering
How to
How to
Produce Data to Kafka
Process & Transform Data
GroupBy Operation
Windows & Aggregations
Configuration
StreamingDataFrame Branching
Consuming Multiple Topics
Advanced Usage
Advanced Usage
Checkpointing
Serialization Formats
Schema Registry
Stateful Processing
Managing Kafka Topics
Using Producer & Consumer
StreamingDataFrame Assignment Rules
Connecting to Quix Cloud
Upgrading Guide
Upgrading Guide
Upgrading from Quix Streams v0.5
API Docs
API Docs
StreamingDataFrame API
Topics API
Context API
Serializers API
Application API
State API
Kafka Producer & Consumer API
Sources API
Sinks API
Kafka Producer & Consumer API
Full Reference
Quix Connectors
Quix Connectors
Quix Streams
Quix Streams
Sources
Sources
CSV Source
File Source
Google Cloud Pub/Sub Source
Kafka Replicator Source
Quix Environment Source
Creating a Custom Source
Sinks
Sinks
Apache Iceberg Sink
CSV Sink
InfluxDB v3 Sink
File Sink
Google Cloud BigQuery Sink
Google Cloud Pub/Sub Sink
Creating a Custom Sink
Contribution Guide
Community and Core Connectors
Quix Cloud
Quix Cloud
Sources
Sources
Confluent Kafka
Environment
InfluxDB 2.0
InfluxDB 3.0
Kafka Connect
MQTT
Postgres CDC
Redis
SQL Change Data Capture
Segment
Snowplow
Sinks
Sinks
AWS S3 Iceberg
BigQuery
Confluent Kafka
InfluxDB 3.0
Kafka Connect
MQTT
Redis
Slack
Websocket
Coming Soon
Coming Soon
Sources
Sources
AmazonGlue source
AmazonS3 source
AmazonSQS source
ApacheIceberg source
ApachePulsar source
Astra source
AzureBlobStorage source
Cassandra source
Chroma source
Clickhouse source
Convex source
Cumulio source
Databend source
Databricks source
Doris source
DuckDB source
DynamoDB source
ElasticSearch source
Exasol source
Firebolt source
GoogleCloudBigQuery source
GoogleCloudFirestore source
GoogleCloudStorage source
GoogleSheets source
Keen source
Kinesis source
Kvdb source
Langchain source
LocalJson source
MariadbColumnstore source
Meilisearch source
MicrosoftSQL source
Milvus source
MongoDB source
Motherduck source
MQTT source
MySQL source
Oracle source
Pgvector source
Pinecone source
Postgres source
PostgresCDC source
PubSub source
Qdrant source
R2 source
RabbitMQ source
Redis source
Redpanda source
Redshift source
Rockset source
Scylla source
Selectdb source
SftpJson source
Snowflake source
SnowflakeCortex source
Sqlite source
StarburstGalaxy source
Teradata source
Tidb source
Timeplus source
Typesense source
Vectara source
Vertica source
Weaviate source
Xata source
Yellowbrick source
Yugabytedb source
Sinks
Sinks
AmazonGlue sink
AmazonS3 sink
AmazonSQS sink
ApachePulsar sink
Astra sink
AzureBlobStorage sink
Cassandra sink
Chroma sink
Clickhouse sink
Convex sink
Cumulio sink
Databend sink
Databricks sink
Doris sink
DuckDB sink
DynamoDB sink
ElasticSearch sink
Exasol sink
Firebolt sink
GoogleCloudBigQuery sink
GoogleCloudFirestore sink
GoogleCloudStorage sink
GoogleSheets sink
Keen sink
Kinesis sink
Kvdb sink
Langchain sink
LocalJson sink
MariadbColumnstore sink
Meilisearch sink
MicrosoftSQL sink
Milvus sink
MongoDB sink
Motherduck sink
MQTT sink
MySQL sink
Oracle sink
Pgvector sink
Pinecone sink
Postgres sink
PostgresCDC sink
PubSub sink
Qdrant sink
R2 sink
RabbitMQ sink
Redis sink
Redpanda sink
Redshift sink
Rockset sink
Scylla sink
Selectdb sink
SftpJson sink
Snowflake sink
SnowflakeCortex sink
Sqlite sink
StarburstGalaxy sink
Teradata sink
Tidb sink
Timeplus sink
Typesense sink
Vectara sink
Vertica sink
Weaviate sink
Xata sink
Yellowbrick sink
Yugabytedb sink
Quix CLI
Quix CLI
Overview
Quickstart
Local Development
Local Development
Running applications locally
Managing secrets locally
Managing YAML variables
Commands Summary
How-To guides
How-To guides
Using the CLI with GitHub Actions
Yaml Reference
Yaml Reference
Pipeline YAML (quix.yaml)
Application YAML (app.yaml)
CLI Reference
CLI Reference
Cloud Commands
Cloud Commands
cloud apps
cloud apps
cloud apps get
cloud apps list
cloud apps library
cloud apps library
cloud apps library list
cloud deployments
cloud deployments
cloud deployments get
cloud deployments list
cloud deployments logs
cloud deployments metrics
cloud deployments start
cloud deployments stop
cloud environments
cloud environments
cloud environments get
cloud environments list
cloud environments use
cloud environments sync
cloud environments tokens
cloud environments tokens
cloud environments tokens get
cloud environments tokens rotate
cloud organisations
cloud organisations
cloud organisations get
cloud projects
cloud projects
cloud projects patch
cloud projects get
cloud projects list
cloud topics
cloud topics
cloud topics get
cloud topics list
cloud users
cloud users
cloud users audit
cloud users permissions
cloud users permissions
cloud users permissions copy
cloud users permissions delete
cloud users permissions edit
cloud users permissions get
cloud users permissions list
cloud users permissions set
cloud users tokens
cloud users tokens
cloud users tokens create
cloud users tokens edit
cloud users tokens list
cloud users tokens revoke
cloud users current
cloud users list
Local Commands
Local Commands
apps
apps
apps library
apps update
apps convert
apps create
apps delete
apps edit
apps list
apps variables
apps variables
apps variables create
apps variables delete
apps variables edit
apps variables export
apps variables import
apps variables list
broker
broker
broker down
broker up
broker topics
broker topics
broker topics list
broker topics read
broker topics update
broker topics write
init
pipeline
pipeline
pipeline deployments
pipeline deployments
pipeline deployments create
pipeline deployments delete
pipeline deployments edit
pipeline deployments get
pipeline deployments list
pipeline down
pipeline logs
pipeline start
pipeline status
pipeline stop
pipeline sync
pipeline up
pipeline update
pipeline view
pipeline topics
pipeline topics
pipeline topics create
pipeline topics delete
pipeline topics edit
pipeline topics get
pipeline topics list
run
sdk
sdk
sdk broker
sdk broker
sdk broker cloud
sdk broker current
sdk broker local
sdk broker pipeline
sdk broker set
sdk broker update
Other Commands
Other Commands
logout
login
contexts
contexts
contexts create
contexts current
contexts list
contexts delete
contexts reset
contexts use
contexts environments
contexts environments
contexts environments clear
contexts environments get
contexts environments use
status
update
use
Quix Cloud
Quix Cloud
Overview
Quickstart
Why Use Quix Cloud
Quix Cloud Tour
Quix Cloud Tour
1. Create your project
1. Create your project
Overview
Clone a project
Fork a project
Create a project
Create an environment
Protected environments
Syncing an environment
Project structure
Create a topic
Data tiers
Create a scratchpad
2. Develop an application
2. Develop an application
Overview
Create an application
Authentication
Authentication
Authenticating Quix Streams
Personal Access Token (PAT)
Streaming Token
Using Code Samples
Integrate your data
Integrate your data
Overview
Ingest your data - source
Ingest your data - source
Using a prebuilt source connector
Reading a CSV file
Polling a REST API
Handling inbound webhooks
Using an external source
Using the Quix Streaming APIs
Using Quix Streams
Posting data to a Quix web app
Handling compressed data
Handling IoT data with MessagePack
Publish your data - sink
Publish your data - sink
Using a prebuilt destination connector
Using an external destination
Exporting Quix data to Jupyter notebooks
Process your data
Process your data
Overview
Types of processing
Types of transform
Generating events
Using Quix Streaming APIs
Using Quix Streaming APIs
Overview
Streaming Writer API
Streaming Writer API
Overview
Setup
HTTP requests
Create a new Stream
Add Stream metadata
Send Parameter data
Send an Event
Streaming Reader API
Streaming Reader API
Overview
Setup
Reading data
Subscription and events
3. Deploy a service
3. Deploy a service
Overview
Environment variables
Secrets management
YAML variables
Configuring network ports
State management
Deploy public services
4. Manage your pipelines
4. Manage your pipelines
Overview
Troubleshooting
Security
MLOps
Using replay service
Testing using Quix data store
Testing multiple environments
Query API
Query API
Overview
Setup
HTTP requests
Paged streams
Filtered streams
Streams with models
Raw data
Aggregate data by time
Aggregate data by tags
Tag filtering
Portal API
Portal API
Overview
Setup
HTTP requests
Security
Integrations
Integrations
Overview
Brokers
Brokers
Overview
Broker settings
Quix
Confluent
Redpanda
Aiven
Upstash
Databases
Databases
InfluxDB
InfluxDB
Overview
Quickstart
Guides
Guides
Using Telegraf
Replacing Flux
Replacing Kapacitor
Alerting
Migrating from v2 to v3
PostgreSQL
PostgreSQL
Overview
Redis
Redis
Overview
Vector Databases
Vector Databases
Overview
Upstash
Upstash
Overview
Qdrant
Qdrant
Overview
Weaviate
Weaviate
Overview
Bring Your Own Cluster (BYOC)
Bring Your Own Cluster (BYOC)
Overview
Requirements
Installation
BYOC vs. Cloud
Knowledge base
Knowledge base
Guides
Guides
What is Quix?
Why stream processing?
What is Kafka?
Reference
Reference
Glossary
Contribute
Planned Connectors
Planned Connectors
kafka-to-apache-airflow
kafka-to-apache-ambari
kafka-to-apache-arrow
kafka-to-apache-atlas
kafka-to-apache-avro
kafka-to-apache-beam
kafka-to-apache-bookkeeper
kafka-to-apache-calcite
kafka-to-apache-camel
kafka-to-apache-cassandra
kafka-to-apache-crunch
kafka-to-apache-curator
kafka-to-apache-drill
kafka-to-apache-druid
kafka-to-apache-flink
kafka-to-apache-gobblin
kafka-to-apache-hadoop
kafka-to-apache-hbase
kafka-to-apache-helix
kafka-to-apache-hudi
kafka-to-apache-iceberg
kafka-to-apache-kafka
kafka-to-apache-karaf
kafka-to-apache-knox
kafka-to-apache-kylin
kafka-to-apache-lens
kafka-to-apache-mahout
kafka-to-apache-manifoldcf
kafka-to-apache-marmotta
kafka-to-apache-mesos
kafka-to-apache-metron
kafka-to-apache-mxnet
kafka-to-apache-nifi
kafka-to-apache-nutch
kafka-to-apache-oozie
kafka-to-apache-opennlp
kafka-to-apache-orc
kafka-to-apache-parquet
kafka-to-apache-pig
kafka-to-apache-pinot
kafka-to-apache-predictionio
kafka-to-apache-pulsar
kafka-to-apache-ranger
kafka-to-apache-reef
kafka-to-apache-sentry
kafka-to-apache-shiro
kafka-to-apache-singa
kafka-to-apache-solr
kafka-to-apache-spark
kafka-to-apache-sqoop
kafka-to-apache-storm
kafka-to-apache-superset
kafka-to-apache-tajo
kafka-to-apache-tez
kafka-to-apache-tika
kafka-to-apache-uima
kafka-to-apache-vxquery
kafka-to-apache-wicket
kafka-to-apache-zeppelin
kafka-to-apache-zookeeper
kafka-to-aws-amplify
kafka-to-aws-app-runner
kafka-to-aws-appsync
kafka-to-aws-athena
kafka-to-aws-auto-scaling
kafka-to-aws-backup
kafka-to-aws-batch
kafka-to-aws-certificate-manager
kafka-to-aws-cloudformation
kafka-to-aws-cloudfront
kafka-to-aws-cloudtrail
kafka-to-aws-cloudwatch
kafka-to-aws-codebuild
kafka-to-aws-codecommit
kafka-to-aws-codedeploy
kafka-to-aws-codepipeline
kafka-to-aws-codestar
kafka-to-aws-cognito
kafka-to-aws-config
kafka-to-aws-data-pipeline
kafka-to-aws-database-migration-service
kafka-to-aws-direct-connect
kafka-to-aws-directory-service
kafka-to-aws-dynamodb
kafka-to-aws-ec2
kafka-to-aws-elastic-beanstalk
kafka-to-aws-elastic-load-balancing
kafka-to-aws-elemental-mediaconvert
kafka-to-aws-elemental-medialive
kafka-to-aws-elemental-mediapackage
kafka-to-aws-elemental-mediastore
kafka-to-aws-elemental-mediatailor
kafka-to-aws-eventbridge
kafka-to-aws-fargate
kafka-to-aws-firewall-manager
kafka-to-aws-glue
kafka-to-aws-iam
kafka-to-aws-iot-core
kafka-to-aws-kinesis
kafka-to-aws-lambda
kafka-to-aws-lightsail
kafka-to-aws-macie
kafka-to-aws-managed-blockchain
kafka-to-aws-marketplace
kafka-to-aws-migration-hub
kafka-to-aws-mobile-hub
kafka-to-aws-opsworks
kafka-to-aws-organizations
kafka-to-aws-outposts
kafka-to-aws-personal-health-dashboard
kafka-to-aws-pinpoint
kafka-to-aws-polly
kafka-to-aws-privatelink
kafka-to-aws-rds
kafka-to-aws-redshift
kafka-to-aws-rekognition
kafka-to-aws-resource-access-manager
kafka-to-aws-robomaker
kafka-to-aws-route-53
kafka-to-aws-s3
kafka-to-aws-sagemaker
kafka-to-aws-secrets-manager
kafka-to-aws-security-hub
kafka-to-aws-server-migration-service
kafka-to-aws-service-catalog
kafka-to-aws-shield
kafka-to-aws-snowball
kafka-to-aws-step-functions
kafka-to-aws-storage-gateway
kafka-to-aws-systems-manager
kafka-to-aws-timestream
kafka-to-aws-transfer-family
kafka-to-aws-transit-gateway
kafka-to-aws-trusted-advisor
kafka-to-aws-vpc
kafka-to-aws-waf
kafka-to-aws-well-architected-tool
kafka-to-aws-x-ray
kafka-to-azure-synapse
kafka-to-bigquery
kafka-to-bitbucket
kafka-to-bokeh
kafka-to-circleci
kafka-to-clickhouse
kafka-to-cloudflare
kafka-to-couchbase
kafka-to-dagster
kafka-to-databricks
kafka-to-datadog
kafka-to-django
kafka-to-domo
kafka-to-dropbox
kafka-to-elasticsearch
kafka-to-exasol
kafka-to-faunadb
kafka-to-firebase
kafka-to-fivetran
kafka-to-flask
kafka-to-git
kafka-to-google-cloud-platform
kafka-to-google-drive
kafka-to-grafana
kafka-to-greenplum
kafka-to-h2o-ai
kafka-to-hasura
kafka-to-heroku
kafka-to-hugo
kafka-to-ibm-db2
kafka-to-informatica
kafka-to-insightly
kafka-to-jenkins
kafka-to-jira
kafka-to-jupyter
kafka-to-kibana
kafka-to-knime
kafka-to-kubernetes
kafka-to-linkedin
kafka-to-looker
kafka-to-lookml
kafka-to-luigi
kafka-to-mailchimp
kafka-to-mariadb
kafka-to-matplotlib
kafka-to-medium
kafka-to-meltano
kafka-to-memcached
kafka-to-microsoft-azure
kafka-to-microsoft-onedrive
kafka-to-microsoft-teams
kafka-to-mongodb
kafka-to-mysql
kafka-to-netezza
kafka-to-netlify
kafka-to-notion
kafka-to-numpy
kafka-to-opencart
kafka-to-oracle
kafka-to-pandas
kafka-to-perl
kafka-to-plotly
kafka-to-postgresql
kafka-to-power-bi
kafka-to-prefect
kafka-to-presto
kafka-to-pytorch
kafka-to-qlik
kafka-to-rapidminer
kafka-to-redis-cloud
kafka-to-redis-enterprise
kafka-to-redis
kafka-to-redisai
kafka-to-redisbloom
kafka-to-redisgears
kafka-to-redisgraph
kafka-to-redisinsight
kafka-to-redisjson
kafka-to-redshift
kafka-to-ringcentral
kafka-to-ruby-on-rails
kafka-to-rust
kafka-to-salesforce
kafka-to-sas
kafka-to-scikit-learn
kafka-to-seaborn
kafka-to-segment
kafka-to-sendgrid
kafka-to-shopify
kafka-to-slack
kafka-to-snowflake
kafka-to-spss
kafka-to-sqlite
kafka-to-supabase
kafka-to-tableau
kafka-to-talend
kafka-to-tensorflow
kafka-to-terraform
kafka-to-trino
kafka-to-twilio
kafka-to-vercel
kafka-to-vertica
kafka-to-vultr
kafka-to-wasabi
kafka-to-webex
kafka-to-webflow
kafka-to-weebly
kafka-to-woocommerce
kafka-to-wordpress
kafka-to-wrike
kafka-to-xml-commons
kafka-to-xml-graphics
kafka-to-xml-rpc
kafka-to-xml-security
kafka-to-xmlbeans
kafka-to-zoho
kafka-to-zoom
Tutorials
Tutorials
Overview
Event detection and alerting featuring InfluxDB and PagerDuty
Event detection and alerting featuring InfluxDB and PagerDuty
Overview
1. Write the Python client
2. Add an external source
3. Add InfluxDB destination
4. Add threshold detection
5. Add PagerDuty alerting
6. Summary
Migrating InfluxDB v2 to v3
Migrating InfluxDB v2 to v3
Overview
1. Install InfluxDB v2
2. Create the project
3. Add InfluxDB v2 source
4. Add InfluxDB v3 destination
5. Summary
Vector Store Embeddings
Predictive maintenance
Predictive maintenance
Overview
1. Get the project
2. Data generator
3. Downsampling
4. Forecast
5. Alerts
6. InfluxDB - raw data
7. InfluxDB - alerts
8. Summary
Blog Index
Blog Index
Archive
Archive
2024
2023
Categories
Categories
ecosystem
industry-insights
industry-insights
Table of contents
Navigating stateful stream processing
A guide to windowing in stream processing
The stream processing glossary
releases
tutorials
Table of contents
Navigating stateful stream processing
A guide to windowing in stream processing
The stream processing glossary
Star Quix Streams
Install Quix Streams
Edit on GitHub
industry-insights
Navigating stateful stream processing
A guide to windowing in stream processing
The stream processing glossary
Back to top