{"version":1,"pages":[{"id":"xXOwD7MwlnJ1gbk2E6Vg","title":"Introduction","pathname":"/warpstream","siteSpaceId":"sitesp_1YOZF","description":"The official documentation for WarpStream, a diskless, Apache Kafka-compatible data streaming platform built directly on top of cloud object stores such as S3.","breadcrumbs":[{"label":"WarpStream"},{"label":"Overview"}]},{"id":"adwgfCxz6dJWW8hWdWrq","title":"Architecture","pathname":"/warpstream/overview/architecture","siteSpaceId":"sitesp_1YOZF","description":"This page provides an overview of WarpStream's architecture.","breadcrumbs":[{"label":"WarpStream"},{"label":"Overview"}]},{"id":"GZVMSPUdDn9MDxDHOfyS","title":"Service Discovery","pathname":"/warpstream/overview/architecture/service-discovery","siteSpaceId":"sitesp_1YOZF","description":"This page explains how WarpStream's custom service discovery mechanism works, as well as how it interacts with Kafka's service discovery system.","breadcrumbs":[{"label":"WarpStream"},{"label":"Overview"},{"label":"Architecture"}]},{"id":"pA4HJ2p1RAmqLfVOVtqo","title":"Write Path","pathname":"/warpstream/overview/architecture/write-path","siteSpaceId":"sitesp_1YOZF","description":"The following page is a summary of WarpStream's approach to persisting data produced from clients.","breadcrumbs":[{"label":"WarpStream"},{"label":"Overview"},{"label":"Architecture"}]},{"id":"oG8WEbqbg1EoZdSFCXtc","title":"Read Path","pathname":"/warpstream/overview/architecture/read-path","siteSpaceId":"sitesp_1YOZF","description":"The following page describes the mechanism for serving Fetch requests from WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Overview"},{"label":"Architecture"}]},{"id":"xjxfD6yG0IOMWwUb5FKW","title":"Life of a Request (Simplified)","pathname":"/warpstream/overview/architecture/life-of-a-request","siteSpaceId":"sitesp_1YOZF","description":"This page explains the flow for a Kafka Produce or Fetch request from client to WarpStream Agent to WarpStream Cloud and back again.","breadcrumbs":[{"label":"WarpStream"},{"label":"Overview"},{"label":"Architecture"}]},{"id":"1yto54LohtJlQvykEQJC","title":"Change Log","pathname":"/warpstream/overview/change-log","siteSpaceId":"sitesp_1YOZF","description":"Contains a history of changes made to the Agent.","breadcrumbs":[{"label":"WarpStream"},{"label":"Overview"}]},{"id":"lBVxM81ar6twsHFmK99n","title":"Install the WarpStream Agent / CLI","pathname":"/warpstream/getting-started/install-the-warpstream-agent","siteSpaceId":"sitesp_1YOZF","description":"This page contains instructions for installing the WarpStream Agent via CURL, Docker, or raw binaries.","breadcrumbs":[{"label":"WarpStream"},{"label":"Getting Started"}]},{"id":"a2wdyG1gGyACF8WqJmVb","title":"Run the Agents Locally","pathname":"/warpstream/getting-started/run-the-agent-locally","siteSpaceId":"sitesp_1YOZF","description":"Instructions on how to run the WarpStream Agent locally for testing / development purposes.","breadcrumbs":[{"label":"WarpStream"},{"label":"Getting Started"}]},{"id":"Dv6iLG3VaT9hTeWcBEGJ","title":"Run the Demo","pathname":"/warpstream/getting-started/demo","siteSpaceId":"sitesp_1YOZF","description":"This page contains instructions on how to run the WarpStream demo.","breadcrumbs":[{"label":"WarpStream"},{"label":"Getting Started"}]},{"id":"NcXkZS45IzThPK8Bpa5A","title":"\"Hello World\" for Apache Kafka","pathname":"/warpstream/getting-started/hello-world-using-kafka","siteSpaceId":"sitesp_1YOZF","description":"This page goes through the basic \"Hello World\" Kafka functionality (produce and consume) with WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Getting Started"}]},{"id":"FsDPXFK6TDcr2JBeHfiA","title":"Deploy the Agents","pathname":"/warpstream/agent-setup/deploy","siteSpaceId":"sitesp_1YOZF","description":"How to deploy the Agents.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"}]},{"id":"02uJFDQaYMfUvThTkp9p","title":"Kubernetes Known Issues","pathname":"/warpstream/agent-setup/deploy/kubernetes-known-issues","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Deploy the Agents"}]},{"id":"jj71PoibSn9INUMWaNXM","title":"Rolling Restarts and Upgrades","pathname":"/warpstream/agent-setup/deploy/rolling-restarts-and-upgrades","siteSpaceId":"sitesp_1YOZF","description":"This page explains how rolling restarts and upgrades work in WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Deploy the Agents"}]},{"id":"zs9xEiujxU7KdrlzReIp","title":"Object Storage Configuration","pathname":"/warpstream/agent-setup/different-object-stores","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to properly configure object storage for BYOC Agent deployments.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"}]},{"id":"eZsxCZE4c9KsN8EbWAeR","title":"Set up Monitoring","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"}]},{"id":"E9GJ8KI4DbOpvYPPBzj4","title":"Diagnostics","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents/diagnostics","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Set up Monitoring"}]},{"id":"JFCY9IFx3Es9XoSjQWhD","title":"Important Metrics and Logs","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents/important-metrics-and-logs","siteSpaceId":"sitesp_1YOZF","description":"On this page, we include a sample list of the most important logs and metrics emitted by the Agents.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Set up Monitoring"}]},{"id":"99vkPaUa61Y8VbFzgv8t","title":"Hosted Prometheus Endpoint","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents/hosted-prometheus-endpoint","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to use WarpStream's hosted prometheus endpoint for collecting control plane metrics.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Set up Monitoring"}]},{"id":"29AzYoVFt1HCbCQSPl2o","title":"Recommended List of Alerts","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents/recommended-list-of-alerts","siteSpaceId":"sitesp_1YOZF","description":"On this page we list the key metrics you should create alerts on.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Set up Monitoring"}]},{"id":"jYaeUxdnSQoV7cNXkqEz","title":"Monitoring Consumer Groups","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents/monitoring-consumer-groups","siteSpaceId":"sitesp_1YOZF","description":"How to monitor your consumer groups.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Set up Monitoring"}]},{"id":"YQsBzoWmgMfVuucESiq4","title":"Datadog Integration","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents/datadog-integration","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Set up Monitoring"}]},{"id":"n5XSmqysuI9H8zMFpgkZ","title":"Pre-made Datadog Dashboard","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents/premade-datadog-dashboard","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Set up Monitoring"}]},{"id":"C6tYWwkKOfOOHxWgZD8q","title":"Pre-made Grafana Dashboard","pathname":"/warpstream/agent-setup/monitor-the-warpstream-agents/pre-made-grafana-dashboard","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Set up Monitoring"}]},{"id":"svqQvCcipSUFxrJ7SAYU","title":"Infrastructure as Code","pathname":"/warpstream/agent-setup/infrastructure-as-code","siteSpaceId":"sitesp_1YOZF","description":"This section contains information on how to configure WarpStream using \"Infrastructure as Code\" tools like Terraform and Helm.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"}]},{"id":"lC0q7A9EVyJzfS16gepo","title":"Terraform Provider","pathname":"/warpstream/agent-setup/infrastructure-as-code/terraform-provider","siteSpaceId":"sitesp_1YOZF","description":"Links to WarpStream Terraform provider resources.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Infrastructure as Code"}]},{"id":"VJXc8piPY1d1oDr8qTPW","title":"Helm charts","pathname":"/warpstream/agent-setup/infrastructure-as-code/helm-charts","siteSpaceId":"sitesp_1YOZF","description":"WarpStream Helm charts.","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Infrastructure as Code"}]},{"id":"uAjyDBWhlCTTPdQNDZzW","title":"Terraform Modules","pathname":"/warpstream/agent-setup/infrastructure-as-code/terraform-modules","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Infrastructure as Code"}]},{"id":"dzrSLJ8O0L5bf7ykgz7m","title":"Protecting important resources from accidental deletion","pathname":"/warpstream/agent-setup/infrastructure-as-code/protecting-important-resources-from-accidental-deletion","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Agent Setup"},{"label":"Infrastructure as Code"}]},{"id":"ZxoK9ihFicBManA8HN2d","title":"Configure Clients","pathname":"/warpstream/kafka/configure-kafka-client","siteSpaceId":"sitesp_1YOZF","description":"This pages explains how to configure your Apache Kafka client with WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"}]},{"id":"4TvVvCeCoeYjoGzpaXab","title":"Tuning for Performance","pathname":"/warpstream/kafka/configure-kafka-client/tuning-for-performance","siteSpaceId":"sitesp_1YOZF","description":"Instructions on how to tune various Kafka clients for performance with WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Configure Clients"}]},{"id":"lcJYuxrteHvAVWRJVUGS","title":"Automatic Fetch Size Auto-tuning","pathname":"/warpstream/kafka/configure-kafka-client/client-configuration-auto-tuning","siteSpaceId":"sitesp_1YOZF","description":"How to allow the Agents to auto-tune settings","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Configure Clients"}]},{"id":"7WYQiWClGxQUtF4HEUio","title":"Configure Clients to Eliminate AZ Networking Costs","pathname":"/warpstream/kafka/configure-kafka-client/configure-clients-to-eliminate-az-networking-costs","siteSpaceId":"sitesp_1YOZF","description":"How to configure your Kafka clients to keep all traffic zone-local.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Configure Clients"}]},{"id":"IT8JXpHmIjyKveUDZxVn","title":"Force Interzone Load Balancing","pathname":"/warpstream/kafka/configure-kafka-client/configure-clients-to-eliminate-az-networking-costs/tune-interzone-load-balancing","siteSpaceId":"sitesp_1YOZF","description":"This page described how to force inter-zone load balancing for clients that don't regularly refresh their Metadata.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Configure Clients"},{"label":"Configure Clients to Eliminate AZ Networking Costs"}]},{"id":"N5AvUTE9w70MutRrgUwq","title":"Configuring Kafka Client ID Features","pathname":"/warpstream/kafka/configure-kafka-client/configuring-kafka-client-id-features","siteSpaceId":"sitesp_1YOZF","description":"WarpStream uses the client id setting that you set on Apache Kafka clients to control how certain features are activated","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Configure Clients"}]},{"id":"OuJwcgAIGUnJbxdy9PlF","title":"Hosted Metadata Endpoint","pathname":"/warpstream/kafka/configure-kafka-client/administrate-your-byoc-clusters-with-serverless","siteSpaceId":"sitesp_1YOZF","description":"This page explains how you can leverage WarpStream's hosted metadata endpoint to administer your WarpStream BYOC clusters from anywhere.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Configure Clients"}]},{"id":"ykMwrdHYgzAo7ZgydnoF","title":"Port Forwarding (K8s)","pathname":"/warpstream/kafka/configure-kafka-client/port-forwarding-k8s","siteSpaceId":"sitesp_1YOZF","description":"This page provides documentation on how to solve a common problem with WarpStream: connecting to Agents deployed in K8s by port-forwarding.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Configure Clients"}]},{"id":"M3z49oANEL7X0rufp3cI","title":"Known Issues","pathname":"/warpstream/kafka/configure-kafka-client/known-issues","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Configure Clients"}]},{"id":"yiSTpyh9ksh6narmJu6J","title":"Manage Security","pathname":"/warpstream/kafka/manage-security","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to manage the various security aspects of WarpStream's Kafka product.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"}]},{"id":"jyvWq4nWrXicnI8zyzPR","title":"ACLs","pathname":"/warpstream/kafka/manage-security/configure-acls","siteSpaceId":"sitesp_1YOZF","description":"The following page provides a management guide for ACLs (Access Control Lists). This document provides instructions on how to enable, disable, create, and delete ACLs for your WarpStream clusters.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Manage Security"}]},{"id":"THTInCi0mgjMDypQxCES","title":"TLS","pathname":"/warpstream/kafka/manage-security/protect-data-in-motion-with-tls-encryption","siteSpaceId":"sitesp_1YOZF","description":"This page described how to configure the Agents to terminate TLS.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Manage Security"}]},{"id":"74AAompwLVcvTrKPA5ZY","title":"SASL Authentication","pathname":"/warpstream/kafka/manage-security/sasl-authentication","siteSpaceId":"sitesp_1YOZF","description":"This page describe how to configure the WarpStream Agents with SASL authentication.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Manage Security"}]},{"id":"LTfi5x3Fis4qRLGECNoX","title":"Mutual TLS (mTLS)","pathname":"/warpstream/kafka/manage-security/mutual-tls-mtls","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to configure the Agents to enforce mTLS.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Manage Security"}]},{"id":"kbYx5zeoQH8dCrsBvBw8","title":"SASL/OAUTHBEARER Authentication","pathname":"/warpstream/kafka/manage-security/sasl-oauthbearer-authentication","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Manage Security"}]},{"id":"QUlg9WQJ6VhIzVqLJCqv","title":"Manage Connectors","pathname":"/warpstream/kafka/manage-connectors","siteSpaceId":"sitesp_1YOZF","description":"This page describes the various options for connector products in WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"}]},{"id":"WkK07D7TpHbnKJjb4gi7","title":"Managed Data Pipelines","pathname":"/warpstream/kafka/manage-connectors/bento","siteSpaceId":"sitesp_1YOZF","description":"This page explains how to use the WarpStream Managed Data Pipelines functionality.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Manage Connectors"}]},{"id":"skKn4Srjqid5OVjiBAxU","title":"Cookbooks","pathname":"/warpstream/kafka/manage-connectors/bento/cookbooks","siteSpaceId":"sitesp_1YOZF","description":"This page contains a collection of WarpStream-specific Bento recipes to help you accomplish common tasks.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Manage Connectors"},{"label":"Managed Data Pipelines"}]},{"id":"J6QEo4z0xq7iI0LAu29b","title":"Deploy (advanced)","pathname":"/warpstream/kafka/advanced-agent-deployment-options","siteSpaceId":"sitesp_1YOZF","description":"This section explains how to configure more advanced deployment options for the WarpStream BYOC Agents.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"}]},{"id":"d1wcyocJXhN2N2RiBJZY","title":"Agent Roles","pathname":"/warpstream/kafka/advanced-agent-deployment-options/splitting-agent-roles","siteSpaceId":"sitesp_1YOZF","description":"How to run different services on different sets of Agents","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"}]},{"id":"pkNJWOZLnZxGnQDf5aW7","title":"Agent Groups","pathname":"/warpstream/kafka/advanced-agent-deployment-options/agent-groups","siteSpaceId":"sitesp_1YOZF","description":"How to split Agents for a cluster into different \"groups\".","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"}]},{"id":"thC2hahxuTov7jjfBu9v","title":"Low Latency Clusters","pathname":"/warpstream/kafka/advanced-agent-deployment-options/low-latency-clusters","siteSpaceId":"sitesp_1YOZF","description":"Configure the WarpStream Agent with lightning topics and a S3 Express, DynamoDB or Spanner storage layer to reduce Produce latency.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"}]},{"id":"E3cF7PI7gCkDM4We8mQU","title":"S3 Express","pathname":"/warpstream/kafka/advanced-agent-deployment-options/low-latency-clusters/s3-express","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"},{"label":"Low Latency Clusters"}]},{"id":"wcoYcKUsVSgxNTnnx9TW","title":"AWS Dynamo DB","pathname":"/warpstream/kafka/advanced-agent-deployment-options/low-latency-clusters/aws-dynamo-db","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"},{"label":"Low Latency Clusters"}]},{"id":"x6tviaJJ31KNQ8VcNVe2","title":"Google Spanner (beta)","pathname":"/warpstream/kafka/advanced-agent-deployment-options/low-latency-clusters/google-spanner-beta","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"},{"label":"Low Latency Clusters"}]},{"id":"ebnqhAMxNpUZUWizMYqa","title":"Lightning topics","pathname":"/warpstream/kafka/advanced-agent-deployment-options/low-latency-clusters/lightning-topics","siteSpaceId":"sitesp_1YOZF","description":"This page explains how to configure topics as Lightning Topics and what impact that will have.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"},{"label":"Low Latency Clusters"}]},{"id":"sHi10enCWvSDmfbJrqbV","title":"Multi-Region Clusters","pathname":"/warpstream/kafka/advanced-agent-deployment-options/multi-region","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"}]},{"id":"suMclnKa8RaLwmL3mzJS","title":"Network Architecture Considerations","pathname":"/warpstream/kafka/advanced-agent-deployment-options/configure-warpstream-agent-within-a-container-or-behind-a-proxy","siteSpaceId":"sitesp_1YOZF","description":"This page describes a variety of different approaches that can be used to deploy WarpStream with more advanced network setups.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"}]},{"id":"Ad8excG27G47BVsXNE3s","title":"Agent Configuration Reference","pathname":"/warpstream/kafka/advanced-agent-deployment-options/agent-configuration","siteSpaceId":"sitesp_1YOZF","description":"Reference documentation for WarpStream Agent flags.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"}]},{"id":"sa1YKNuCCtzK8Wb2BZum","title":"Reducing Infrastructure Costs","pathname":"/warpstream/kafka/advanced-agent-deployment-options/reducing-infrastructure-costs","siteSpaceId":"sitesp_1YOZF","description":"How to reduce infrastructure costs for WarpStream BYOC clusters.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"}]},{"id":"RfhAMgcGi4H2cDD50Nwf","title":"Ripcord","pathname":"/warpstream/kafka/advanced-agent-deployment-options/ripcord","siteSpaceId":"sitesp_1YOZF","description":"Ripcord enables WarpStream Agents to continue ingesting data and accepting Produce requests even when the control plane is unavailable.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Deploy (advanced)"}]},{"id":"I6UQOuGGyAdJTx556FIe","title":"Orbit (Cluster Linking)","pathname":"/warpstream/kafka/orbit","siteSpaceId":"sitesp_1YOZF","description":"Replicate and migrate Kafka clusters.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"}]},{"id":"4JandefIuEKD6R9I5WkZ","title":"Benchmark","pathname":"/warpstream/kafka/benchmarking","siteSpaceId":"sitesp_1YOZF","description":"How to Benchmark WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"}]},{"id":"OViRhyqLtpzrSK9mSsLc","title":"Reference","pathname":"/warpstream/kafka/reference","siteSpaceId":"sitesp_1YOZF","description":"This section contains various reference information about the WarpStream Kafka product.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"}]},{"id":"NR1rcEqEgCM0NAlfNRLz","title":"Compression","pathname":"/warpstream/kafka/reference/compression","siteSpaceId":"sitesp_1YOZF","description":"Overview of how compression works in WarpStream and how to configure it.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"}]},{"id":"SPice9AuJ3AGc5S2y5or","title":"Protocol and Feature Support","pathname":"/warpstream/kafka/reference/protocol-and-feature-support","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"}]},{"id":"fXkCLNkvDvA8lit27plt","title":"Kafka vs WarpStream Configuration Reference","pathname":"/warpstream/kafka/reference/protocol-and-feature-support/kafka-vs-warpstream-configuration-reference","siteSpaceId":"sitesp_1YOZF","description":"The purpose of this page is to compare configuration options in Kafka and WarpStream 1:1 as applicable.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"},{"label":"Protocol and Feature Support"}]},{"id":"rcwmUzgkr4rx2i2F3cbg","title":"Compacted topics","pathname":"/warpstream/kafka/reference/protocol-and-feature-support/compacted-topics","siteSpaceId":"sitesp_1YOZF","description":"Information about compacted topics in WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"},{"label":"Protocol and Feature Support"}]},{"id":"qC7LyPpt9ZsJygEz4tXF","title":"Topic Configuration Reference","pathname":"/warpstream/kafka/reference/protocol-and-feature-support/topic-configuration-reference","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"},{"label":"Protocol and Feature Support"}]},{"id":"dSgHSDj9z8HbfgMC3CtT","title":"HTTP Endpoints","pathname":"/warpstream/kafka/reference/protocol-and-feature-support/http-endpoints","siteSpaceId":"sitesp_1YOZF","description":"This pages describes the HTTP endpoints available in the WarpStream Kafka product.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"},{"label":"Protocol and Feature Support"}]},{"id":"hJvbic9gDVSmsjOJOKNx","title":"Partitions Auto-Scaler","pathname":"/warpstream/kafka/reference/partitions-auto-scaler-beta","siteSpaceId":"sitesp_1YOZF","description":"This page describes the functionality of WarpStream's Partitions Auto-Scaler.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"}]},{"id":"lkSBhHGD1G6YzxOp6DQX","title":"Serverless Clusters","pathname":"/warpstream/kafka/reference/serverless-clusters","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"}]},{"id":"rO2tgThkegrF812aUQYj","title":"Partition Assignment Strategies","pathname":"/warpstream/kafka/reference/partition-assignment-strategies","siteSpaceId":"sitesp_1YOZF","description":"This page explains the various different partition assignment strategies in WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Kafka"},{"label":"Reference"}]},{"id":"Dr2PEsXQKtQlxqG0LpPK","title":"Tableflow Setup","pathname":"/warpstream/tableflow/tableflow","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to setup WarpStream Tableflow.","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"}]},{"id":"yXG86r74DZoXKmlfiekm","title":"Monitoring Tableflow","pathname":"/warpstream/tableflow/monitoring","siteSpaceId":"sitesp_1YOZF","description":"Key metrics, diagnostics, events, and recommended alerts for Tableflow clusters.","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"}]},{"id":"ZwF4VyjsPbD9mflKY6uN","title":"Iceberg REST Catalog","pathname":"/warpstream/tableflow/iceberg-catalog","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to connect with Tableflow's read-only REST catalog.","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"}]},{"id":"NlzfzFdzC9tVILx4qJPq","title":"Integrate With Query Engines and External Catalogs","pathname":"/warpstream/tableflow/catalogs-and-query-engines","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"}]},{"id":"z2AYuIIe8uKPY0tuoBUP","title":"Snowflake","pathname":"/warpstream/tableflow/catalogs-and-query-engines/snowflake","siteSpaceId":"sitesp_1YOZF","description":"This pages describes how to integrate Tableflow with Snowflake so that you can query Iceberg tables created by WarpStream in Snowflake.","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"Vg7SdDox4XFHoBVK1tWQ","title":"Databricks Unity","pathname":"/warpstream/tableflow/catalogs-and-query-engines/databricks","siteSpaceId":"sitesp_1YOZF","description":"This pages describes how to integrate Tableflow with Databricks so that you can query Iceberg tables created by WarpStream in Databricks.","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"zWJACkTjL5H9i7EvAsux","title":"BigQuery","pathname":"/warpstream/tableflow/catalogs-and-query-engines/bigquery","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate Tableflow with Google BigQuery so that you can query Iceberg tables created by WarpStream directly in BigQuery.","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"zn98Llc2lSUSm2zWKjWW","title":"BigLake","pathname":"/warpstream/tableflow/catalogs-and-query-engines/biglake","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate with Google BigLake Metastore so that you can query Iceberg tables created by Tableflow directly in BigQuery via BigLake.","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"IaGPnT19vXiLDqAcHyCx","title":"DuckDB","pathname":"/warpstream/tableflow/catalogs-and-query-engines/duckdb","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"i4LRXb9VRPgGUisMhIGt","title":"ClickHouse","pathname":"/warpstream/tableflow/catalogs-and-query-engines/clickhouse","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"mqLqT9AbPX00lo0qORUG","title":"AWS Glue","pathname":"/warpstream/tableflow/catalogs-and-query-engines/aws-glue","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"dYbkDBjoU0AXnaZvbPml","title":"Amazon Athena","pathname":"/warpstream/tableflow/catalogs-and-query-engines/amazon-athena","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"22W3neoDDrWIw2I8aQ7P","title":"Hive Metadata Store","pathname":"/warpstream/tableflow/catalogs-and-query-engines/hive-metadata-store","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"},{"label":"Integrate With Query Engines and External Catalogs"}]},{"id":"jOD4lm4wlD6CwFqVs1N0","title":"API Reference","pathname":"/warpstream/tableflow/api-reference","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Tableflow"}]},{"id":"RS3n58Bz5BcmrIjoGnxQ","title":"Setup","pathname":"/warpstream/schema-registry/warpstream-byoc-schema-registry","siteSpaceId":"sitesp_1YOZF","description":"This page explains how to setup WarpStream's BYOC Schema Registry.","breadcrumbs":[{"label":"WarpStream"},{"label":"Schema Registry"}]},{"id":"INvQgyGuqagJEECU1R25","title":"Enforce Schemas","pathname":"/warpstream/schema-registry/schema-validation","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to configure the topic and agent to perform schema validation.","breadcrumbs":[{"label":"WarpStream"},{"label":"Schema Registry"}]},{"id":"uioki8yYUXsYkITewaJe","title":"Schema Linking","pathname":"/warpstream/schema-registry/warpstream-schema-linking","siteSpaceId":"sitesp_1YOZF","description":"Replicate and migrate schemas to WarpStream BYOC Schema Registry.","breadcrumbs":[{"label":"WarpStream"},{"label":"Schema Registry"}]},{"id":"gSrqpnkexNoJNU7ClC7G","title":"Manage Security","pathname":"/warpstream/schema-registry/manage-security","siteSpaceId":"sitesp_1YOZF","description":"This section explains how to manage security for WarpStream's Schema Registry product.","breadcrumbs":[{"label":"WarpStream"},{"label":"Schema Registry"}]},{"id":"FZ012qTRlhpKVnkmLnuw","title":"Basic Authentication","pathname":"/warpstream/schema-registry/manage-security/basic-authentication","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Schema Registry"},{"label":"Manage Security"}]},{"id":"8dPHiH5mytuYZDGP72UP","title":"Billing","pathname":"/warpstream/reference/billing","siteSpaceId":"sitesp_1YOZF","description":"An overview of WarpStream's billing model.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"CyjYiDAhxUx5oFjxKbuD","title":"Direct billing","pathname":"/warpstream/reference/billing/direct-billing","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Billing"}]},{"id":"lgjgbVeBVi4OfKvW7Ycz","title":"AWS Marketplace","pathname":"/warpstream/reference/billing/aws-marketplace","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Billing"}]},{"id":"qn5rn2VUdM66pK18Dxaj","title":"Audit Logs","pathname":"/warpstream/reference/audit-logs","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to setup WarpStream Audit Logs.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"1TKYILf9oFdmrnwqcDME","title":"Events","pathname":"/warpstream/reference/events","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"u64MQYL8DnvYjk7qHcKo","title":"MCP Server","pathname":"/warpstream/reference/mcp-server","siteSpaceId":"sitesp_1YOZF","description":"This page describes the WarpStream Console MCP (Model Context Protocol) server for IDEs and AI assistants.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"F8FnoMVlUZJz32ygFEar","title":"Accessing the Confluent Support Portal","pathname":"/warpstream/reference/accessing-the-confluent-support-portal","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to access the Confluent customer support portal.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"3kB5VIo7pkhcW1vedEXs","title":"Security and Privacy Considerations","pathname":"/warpstream/reference/security-and-privacy-considerations","siteSpaceId":"sitesp_1YOZF","description":"This page describes the various security and privacy considerations for WarpStream's BYOC deployment model.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"yIbgJxRCeHBFxmMW7D3A","title":"Manage Console Access","pathname":"/warpstream/reference/manage-console-access","siteSpaceId":"sitesp_1YOZF","description":"This section describes the various option for managing access to WarpStream's console.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"99QXZ5ohoSUiDDAME5aW","title":"Enable SAML Single Sign-on (SSO)","pathname":"/warpstream/reference/manage-console-access/enable-saml-single-sign-on-sso","siteSpaceId":"sitesp_1YOZF","description":"This page explains how to configure WarpStream's SAML / SSO functionality.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Manage Console Access"}]},{"id":"FESVe3GIWm1tayxn6ux4","title":"Trusted Domains","pathname":"/warpstream/reference/manage-console-access/trusted-domains","siteSpaceId":"sitesp_1YOZF","description":"This page explains how to configure WarpStream's trusted domains functionality.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Manage Console Access"}]},{"id":"wSeMWjAblCC8Z5GsQer1","title":"Workspaces and Access Controls","pathname":"/warpstream/reference/manage-console-access/workspaces-and-access-controls","siteSpaceId":"sitesp_1YOZF","description":"Overview of access control in the WarpStream web console.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Manage Console Access"}]},{"id":"ao4WMx6MPfk8A4tOf02c","title":"Secrets Overview","pathname":"/warpstream/reference/secrets-overview","siteSpaceId":"sitesp_1YOZF","description":"This page provides an overview of the various secrets defined by WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"2ke7U9bbumos33P1mTXQ","title":"API Reference","pathname":"/warpstream/reference/api-reference","siteSpaceId":"sitesp_1YOZF","description":"This section of the documentation contains the API reference for the WarpStream public API endpoints.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"KsAA7j1ZtxPHhZuCXRGb","title":"API Keys","pathname":"/warpstream/reference/api-reference/api-keys","siteSpaceId":"sitesp_1YOZF","description":"APIs for interacting with API Keys.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"x6bwOkLAbjhJ4BE23Yd9","title":"Create","pathname":"/warpstream/reference/api-reference/api-keys/create","siteSpaceId":"sitesp_1YOZF","description":"Create a new API Key.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"API Keys"}]},{"id":"UcM2vN9alokfLXDmrG3e","title":"Delete","pathname":"/warpstream/reference/api-reference/api-keys/delete","siteSpaceId":"sitesp_1YOZF","description":"Delete an API key by ID. The deleted API key must belong to the same workspace as the API key used to authenticate the request.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"API Keys"}]},{"id":"XGtlnleTes8TXOfVNhMu","title":"List","pathname":"/warpstream/reference/api-reference/api-keys/list","siteSpaceId":"sitesp_1YOZF","description":"List all API Keys in a workspace.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"API Keys"}]},{"id":"Za4LoVpsLfyXnmYdUK5H","title":"Virtual Clusters","pathname":"/warpstream/reference/api-reference/virtual-clusters","siteSpaceId":"sitesp_1YOZF","description":"APIs for interacting with Virtual Clusters.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"2p2Tjk6rOIyYbHeuIQiv","title":"Create","pathname":"/warpstream/reference/api-reference/virtual-clusters/create","siteSpaceId":"sitesp_1YOZF","description":"Create a new Virtual Cluster.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"x8fr2GMjowomsjjTucWs","title":"Delete","pathname":"/warpstream/reference/api-reference/virtual-clusters/delete","siteSpaceId":"sitesp_1YOZF","description":"Delete a Virtual Cluster by ID and name.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"Q8IdIvHGeQRi196M9nmI","title":"Describe","pathname":"/warpstream/reference/api-reference/virtual-clusters/describe","siteSpaceId":"sitesp_1YOZF","description":"Describe a specific Virtual Cluster by ID.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"12uBpd8IGFEMrIrieTZL","title":"List","pathname":"/warpstream/reference/api-reference/virtual-clusters/list","siteSpaceId":"sitesp_1YOZF","description":"List all Virtual Clusters in your account.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"5X3D0e1AMFKgywlA1T9a","title":"Create a Multi-Region Cluster","pathname":"/warpstream/reference/api-reference/virtual-clusters/create-a-multi-region-cluster","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"zJ1kFjfLILFVtsZ4FNJe","title":"DescribeConfiguration","pathname":"/warpstream/reference/api-reference/virtual-clusters/describeconfiguration","siteSpaceId":"sitesp_1YOZF","description":"Describe the configuration of a specific Virtual Cluster by ID.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"tS94LWdUhiQ96YYEyP4v","title":"UpdateConfiguration","pathname":"/warpstream/reference/api-reference/virtual-clusters/updateconfiguration","siteSpaceId":"sitesp_1YOZF","description":"Update the configuration of a specific Virtual Cluster by ID.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"0K9sjKIZftzfh1Gzftj5","title":"Rename","pathname":"/warpstream/reference/api-reference/virtual-clusters/rename","siteSpaceId":"sitesp_1YOZF","description":"Rename a virtual cluster.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"Y4fiyJNFpaYaVcyDL8v6","title":"Update Tier","pathname":"/warpstream/reference/api-reference/virtual-clusters/rename-1","siteSpaceId":"sitesp_1YOZF","description":"Update a virtual cluster's tier.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters"}]},{"id":"VD2Zmfxf3vqsnFHBAgKW","title":"Virtual Clusters Credentials","pathname":"/warpstream/reference/api-reference/virtual-clusters-credentials","siteSpaceId":"sitesp_1YOZF","description":"APIs for interacting with Virtual Clusters Credentials.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"Wa1wvawTgs7XJmovk08x","title":"Create","pathname":"/warpstream/reference/api-reference/virtual-clusters-credentials/create","siteSpaceId":"sitesp_1YOZF","description":"Create new Virtual Cluster Credentials.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters Credentials"}]},{"id":"uhcOXzRUKTJjHgmXJ6MY","title":"Delete","pathname":"/warpstream/reference/api-reference/virtual-clusters-credentials/delete","siteSpaceId":"sitesp_1YOZF","description":"Delete a Virtual Cluster by ID and name.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters Credentials"}]},{"id":"QndeCuYLogiFs2iuT3OY","title":"List","pathname":"/warpstream/reference/api-reference/virtual-clusters-credentials/list","siteSpaceId":"sitesp_1YOZF","description":"List all Virtual Clusters Credentials of a given Virtual Cluster.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Virtual Clusters Credentials"}]},{"id":"sJEyHXeNr7Mph44louhD","title":"ACLs","pathname":"/warpstream/reference/api-reference/acls","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"ZEjhdoQgw4Jpe5zDyXPd","title":"Create ACL","pathname":"/warpstream/reference/api-reference/acls/create-acl","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"ACLs"}]},{"id":"lgEINwtj82Ua7uzVe9lA","title":"List ACLs","pathname":"/warpstream/reference/api-reference/acls/list-acls","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"ACLs"}]},{"id":"8g3sajAbMgcmaks4kht8","title":"Delete ACLs","pathname":"/warpstream/reference/api-reference/acls/delete-acls","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"ACLs"}]},{"id":"EapMmxfRYYIt5WiyGNFF","title":"Monitoring","pathname":"/warpstream/reference/api-reference/monitoring","siteSpaceId":"sitesp_1YOZF","description":"APIs for monitoring WarpStream and Consumers.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"NtjvoSoW16PCzazWX89K","title":"Describe All Consumer Groups","pathname":"/warpstream/reference/api-reference/monitoring/describe-all-consumer-groups","siteSpaceId":"sitesp_1YOZF","description":"Describe all consumer groups.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Monitoring"}]},{"id":"nRU1bxCxw8cjHOR414H0","title":"Describe Account Quotas","pathname":"/warpstream/reference/api-reference/monitoring/describe-quotas","siteSpaceId":"sitesp_1YOZF","description":"Describe account quotas.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Monitoring"}]},{"id":"fyZiK3tZ326ehPCWgkvK","title":"Pipelines","pathname":"/warpstream/reference/api-reference/pipelines","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"5OxReMbi6KXRP7elbqkz","title":"List Pipelines","pathname":"/warpstream/reference/api-reference/pipelines/list-pipelines","siteSpaceId":"sitesp_1YOZF","description":"Lists all pipelines within a virtual cluster.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Pipelines"}]},{"id":"G5uRPVMxjfKyX0UaVhJu","title":"Create Pipeline","pathname":"/warpstream/reference/api-reference/pipelines/create-pipeline","siteSpaceId":"sitesp_1YOZF","description":"Creates a new pipeline in a virtual cluster.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Pipelines"}]},{"id":"UnVVYSN4VMJza510NLkm","title":"Delete Pipeline","pathname":"/warpstream/reference/api-reference/pipelines/delete-pipeline","siteSpaceId":"sitesp_1YOZF","description":"Deletes a specific pipeline configuration.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Pipelines"}]},{"id":"BehmNdQAsyvuPGRbW6Dt","title":"Describe Pipeline","pathname":"/warpstream/reference/api-reference/pipelines/describe-pipeline","siteSpaceId":"sitesp_1YOZF","description":"Retrieves details about a specific pipeline, including its configurations.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Pipelines"}]},{"id":"4mQ5vqr4XsLL2acTkgQC","title":"Create Pipeline Configuration","pathname":"/warpstream/reference/api-reference/pipelines/create-pipeline-configuration","siteSpaceId":"sitesp_1YOZF","description":"Creates a configuration for a pipeline.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Pipelines"}]},{"id":"zZFmulKsTzSWhgB05wW4","title":"Change Pipeline State","pathname":"/warpstream/reference/api-reference/pipelines/change-pipeline-state","siteSpaceId":"sitesp_1YOZF","description":"Changes the state of an existing pipeline.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Pipelines"}]},{"id":"IjFPY0PciRL6S6E6djHu","title":"Invitations","pathname":"/warpstream/reference/api-reference/invitations","siteSpaceId":"sitesp_1YOZF","description":"APIs to manage invitations to a WarpStream account","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"4IwxEKZKQBs3IvRpJC2N","title":"Create","pathname":"/warpstream/reference/api-reference/invitations/create","siteSpaceId":"sitesp_1YOZF","description":"Create invitations.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Invitations"}]},{"id":"eKOfR4a5Uv3Mo2QF8ifs","title":"Invoices","pathname":"/warpstream/reference/api-reference/invoices","siteSpaceId":"sitesp_1YOZF","description":"API endpoint for retrieving current and past invoices","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"bLc5a1RjXHSvznFV9oaZ","title":"Get Pending Invoice","pathname":"/warpstream/reference/api-reference/invoices/get-pending-invoice","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Invoices"}]},{"id":"91Dw4UZufIEY21YkeEB4","title":"Get Past Invoice","pathname":"/warpstream/reference/api-reference/invoices/get-past-invoice","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Invoices"}]},{"id":"EsY2aUVkfDXkOQ2s8KJI","title":"Get Invoice Breakdowns","pathname":"/warpstream/reference/api-reference/invoices/get-invoice-breakdowns","siteSpaceId":"sitesp_1YOZF","description":"Provides a daily breakdown during a time period.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Invoices"}]},{"id":"eK2qsJJyVTrAN4qSYXee","title":"Tableflow","pathname":"/warpstream/reference/api-reference/tableflow","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"ftnHHhs5GAW6aK4RNa3J","title":"List Tables","pathname":"/warpstream/reference/api-reference/tableflow/list-tables","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Tableflow"}]},{"id":"2ffSt6c3jgFmndDCBLDs","title":"Get Table","pathname":"/warpstream/reference/api-reference/tableflow/get-table","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Tableflow"}]},{"id":"RCGvdrPJrkEgKpDyRm36","title":"Delete/Recreate Table","pathname":"/warpstream/reference/api-reference/tableflow/delete-recreate-table","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Tableflow"}]},{"id":"2rmTAVILgXTYL2QfJpWe","title":"Topics","pathname":"/warpstream/reference/api-reference/topics","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"rMISeNVNKhErvc3Os1jv","title":"Create topic","pathname":"/warpstream/reference/api-reference/topics/create-topic","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Topics"}]},{"id":"wEuCouc8dht7r1plxmxm","title":"List topics","pathname":"/warpstream/reference/api-reference/topics/list-topics","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Topics"}]},{"id":"yX1nQEKG0ihRRv9MJXgT","title":"Describe topic","pathname":"/warpstream/reference/api-reference/topics/describe-topic","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Topics"}]},{"id":"C2uwmYZ6tg9e8adgUfc8","title":"Update topic","pathname":"/warpstream/reference/api-reference/topics/update-topic","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Topics"}]},{"id":"iaKMlOLWkI9jlQSXnHXA","title":"Delete topic","pathname":"/warpstream/reference/api-reference/topics/delete-topic","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Topics"}]},{"id":"Y5m6DKaPWtVRJ8lhkrvX","title":"Undelete topic","pathname":"/warpstream/reference/api-reference/topics/undelete-topic","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Topics"}]},{"id":"Rr3jAubDkekCnoPNML4i","title":"Users","pathname":"/warpstream/reference/api-reference/users","siteSpaceId":"sitesp_1YOZF","description":"APIs for interacting with Users","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"gyOb5ubsTLmZPtdno25w","title":"Delete","pathname":"/warpstream/reference/api-reference/users/delete","siteSpaceId":"sitesp_1YOZF","description":"Delete a User.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Users"}]},{"id":"X0NeZM29SPhqCaURKWRv","title":"List","pathname":"/warpstream/reference/api-reference/users/list","siteSpaceId":"sitesp_1YOZF","description":"List all Users in the account.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Users"}]},{"id":"Mi6SUpBvEpeyRorwYFdv","title":"Update Roles","pathname":"/warpstream/reference/api-reference/users/update-roles","siteSpaceId":"sitesp_1YOZF","description":"Assign and unassign a User's roles.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Users"}]},{"id":"XpHfsLuRP7A8AopQYLFa","title":"User Roles","pathname":"/warpstream/reference/api-reference/user-roles","siteSpaceId":"sitesp_1YOZF","description":"APIs for interacting with User Roles","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"N10n6K8H4cEbGMdNYvIx","title":"Create","pathname":"/warpstream/reference/api-reference/user-roles/create","siteSpaceId":"sitesp_1YOZF","description":"Create a new User Role.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"User Roles"}]},{"id":"3B9Wbq7W7DYJBdby8T3B","title":"Delete","pathname":"/warpstream/reference/api-reference/user-roles/delete","siteSpaceId":"sitesp_1YOZF","description":"Delete a User Role.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"User Roles"}]},{"id":"Hv1S82DVu5yuM0AthQij","title":"List","pathname":"/warpstream/reference/api-reference/user-roles/list","siteSpaceId":"sitesp_1YOZF","description":"List all User Roles in the account.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"User Roles"}]},{"id":"pZRQbZpnx1dBi4eKKLm4","title":"Update","pathname":"/warpstream/reference/api-reference/user-roles/update","siteSpaceId":"sitesp_1YOZF","description":"Update a User Role.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"User Roles"}]},{"id":"nbbTVqSjKGxDHller0iF","title":"Workspaces","pathname":"/warpstream/reference/api-reference/workspaces","siteSpaceId":"sitesp_1YOZF","description":"APIs for interacting with Workspaces.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"}]},{"id":"gBZ2LO3L9yidrMNQgA8m","title":"Create","pathname":"/warpstream/reference/api-reference/workspaces/create","siteSpaceId":"sitesp_1YOZF","description":"Create a new Workspace.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Workspaces"}]},{"id":"ajS1BBiOiDfc9d1LUgH0","title":"Delete","pathname":"/warpstream/reference/api-reference/workspaces/delete","siteSpaceId":"sitesp_1YOZF","description":"Delete a workspace.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Workspaces"}]},{"id":"jQZ0Jimpv4GMKndRzmZ4","title":"List","pathname":"/warpstream/reference/api-reference/workspaces/list","siteSpaceId":"sitesp_1YOZF","description":"List all Workspaces in your account.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Workspaces"}]},{"id":"RxDRY3eJoQKb6YzepAna","title":"Rename","pathname":"/warpstream/reference/api-reference/workspaces/rename","siteSpaceId":"sitesp_1YOZF","description":"Rename a Workspace.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"API Reference"},{"label":"Workspaces"}]},{"id":"QiL63gxhiGkbChydPaHQ","title":"CLI Reference","pathname":"/warpstream/reference/cli-reference","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"N3b4iPLMzaSZO3tQATmQ","title":"warpstream agent","pathname":"/warpstream/reference/cli-reference/warpstream-agent","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"}]},{"id":"g7VF8J9kNwNIWspxnioB","title":"warpstream demo","pathname":"/warpstream/reference/cli-reference/warpstream-demo","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"}]},{"id":"yieOwLKDSUij6kPCX6EV","title":"warpstream cli","pathname":"/warpstream/reference/cli-reference/warpstream-kcmd","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"}]},{"id":"cbMXa6KgQbxmK4lQ3xib","title":"warpstream cli-beta","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"}]},{"id":"du5FzeTHEcwduAJ9IheU","title":"benchmark-consumer","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta/benchmark-consumer","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"},{"label":"warpstream cli-beta"}]},{"id":"CxLwkY4GtNmD5SDxPtAQ","title":"benchmark-producer","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta/benchmark-producer","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"},{"label":"warpstream cli-beta"}]},{"id":"yTWpHzQk7nYuPxwbW64d","title":"console-consumer","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta/console-consumer","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"},{"label":"warpstream cli-beta"}]},{"id":"z2uMhnxFuOWsL3z4blXc","title":"console-producer","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta/console-producer","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"},{"label":"warpstream cli-beta"}]},{"id":"MmMS0pxrEhBP3kbfB0cZ","title":"consumer-group-lag","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta/consumer-group-lag","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"},{"label":"warpstream cli-beta"}]},{"id":"9GIBHYzSCS9x5rjsBHPe","title":"diagnose-record","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta/diagnose-record","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"},{"label":"warpstream cli-beta"}]},{"id":"KFNmGx7gbTtSOadMWzFO","title":"file-reader","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta/file-reader","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"},{"label":"warpstream cli-beta"}]},{"id":"1O5vvTPe2X6XRuL8HeBL","title":"file-scrubber","pathname":"/warpstream/reference/cli-reference/warpstream-cli-beta/file-scrubber","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"},{"label":"warpstream cli-beta"}]},{"id":"zwBj3n9ekAbZBGct8pH2","title":"warpstream playground","pathname":"/warpstream/reference/cli-reference/warpstream-playground","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"CLI Reference"}]},{"id":"fPbEftLUweBVWSvFyIZ3","title":"Integrations","pathname":"/warpstream/reference/integrations","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"1jQEarIrnDGWcLxj18g7","title":"Arroyo","pathname":"/warpstream/reference/integrations/arroyo","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate WarpStream with Arroyo, a distributed stream processing engine written in Rust, that is designed to efficiently perform statement computations on streams of data.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"6VRbyz3ggOEEW79pREnW","title":"AWS Lambda Triggers","pathname":"/warpstream/reference/integrations/aws-lambda-triggers","siteSpaceId":"sitesp_1YOZF","description":"This page explains how to use WarpStream with AWS's Self Managed Apache Kafka Trigger","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"dXKt20WctDcUSPBvuRiB","title":"ClickHouse","pathname":"/warpstream/reference/integrations/clickhouse","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate WarpStream with ClickHouse, ingest data from WarpStream into ClickHouse, and query the data in ClickHouse.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"MhbP3mGmzFKhPIZcNvXm","title":"Debezium","pathname":"/warpstream/reference/integrations/use-warpstream-with-debezium","siteSpaceId":"sitesp_1YOZF","description":"Instructions on how to use WarpStream with Debezium.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"Vc1PmwERDu6dBMyWF5uq","title":"Decodable","pathname":"/warpstream/reference/integrations/decodable","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate WarpStream with Decodable, ingest data into Decodable from WarpStream, and query the data in Decodable.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"ft1KYji0DW344cBgVJPA","title":"DeltaStream","pathname":"/warpstream/reference/integrations/deltastream","siteSpaceId":"sitesp_1YOZF","description":"Learn how to connect DeltaStream and WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"e60Yw8d04dFfiEfKafia","title":"docker-compose","pathname":"/warpstream/reference/integrations/use-the-agent-in-docker-compose","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to configure the WarpStream Agent's so they run in docker-compose.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"NP9AzIGwde07tWyi4nHk","title":"DuckDB","pathname":"/warpstream/reference/integrations/duckdb","siteSpaceId":"sitesp_1YOZF","description":"DuckDB is an open-source, column-oriented, relational database management system (RDBMS) designed for analytical processing and interactive querying.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"4hq7WdWCXRo6gNRZ08eu","title":"ElastiFlow","pathname":"/warpstream/reference/integrations/elastiflow","siteSpaceId":"sitesp_1YOZF","description":"ElastiFlow is a network flow and SNMP analytics/monitoring solution that enables insights into network performance and security using NetFlow, IPFIX, sFlow, and SNMP with data platforms like Kafka.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"uMBC9D3mMFSFZjIot5XD","title":"Estuary","pathname":"/warpstream/reference/integrations/estuary","siteSpaceId":"sitesp_1YOZF","description":"Estuary allows you to build real-time ETL/ELT data pipelines between various platforms supported by an array of connectors.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"5DbQ4mNe4sXUP0Hserbr","title":"Fly.io","pathname":"/warpstream/reference/integrations/deploy-warpstream-to-fly.io","siteSpaceId":"sitesp_1YOZF","description":"Instructions on how to deploy the WarpStream Agents to Fly.io","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"auPCbhbEOqUucvv9Dz52","title":"Imply","pathname":"/warpstream/reference/integrations/imply","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate, ingest and query data in Imply from WarpStream. Imply is powered by Apache Druid, a real-time analytics database.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"Xqg7MGhGkPMyFqF8HqAq","title":"InfluxDB","pathname":"/warpstream/reference/integrations/influxdb","siteSpaceId":"sitesp_1YOZF","description":"InfluxDB is an open-source time series database that is a perfect companion to WarpStream's Apache Kafka-compatible clusters.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"OFfs8egY5EXaVARbyXiJ","title":"Kafbat UI/kafka-ui","pathname":"/warpstream/reference/integrations/kafbat-ui-kafka-ui","siteSpaceId":"sitesp_1YOZF","description":"Kafbat UI and kafka-ui are web UIs for managing and monitoring Kafka clusters.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"MyrZEmGz5XpAW2eKK25E","title":"Kestra","pathname":"/warpstream/reference/integrations/kestra","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate WarpStream with Kestra. Kestra is an event-driven data orchestration platform with a UI and command-line interface.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"m90xuFayqxmnEfuVTr2e","title":"Materialize","pathname":"/warpstream/reference/integrations/materialize","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to set up a connection between WarpStream and Materialize, ingest data into Materialize, and create a materialized view of this data.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"kRPiMb0O8WpxBjd27ts9","title":"MinIO","pathname":"/warpstream/reference/integrations/minio","siteSpaceId":"sitesp_1YOZF","description":"Instructions on integrating WarpStream with MinIO.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"cBezBCvdo9zdIIIhHYuW","title":"MirrorMaker","pathname":"/warpstream/reference/integrations/mirrormaker","siteSpaceId":"sitesp_1YOZF","description":"This page describes the settings tweaks you may have to do to leverage MirrorMaker to migrate to Warpstream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"odOwOYwBKeISteCYwtIx","title":"MotherDuck","pathname":"/warpstream/reference/integrations/motherduck","siteSpaceId":"sitesp_1YOZF","description":"MotherDuck provides cloud-based, serverless access to DuckDB","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"fGkM04iVkTflG7BLa1AY","title":"ngrok","pathname":"/warpstream/reference/integrations/ngrok","siteSpaceId":"sitesp_1YOZF","description":"How to leverage ngrok for testing WarpStream Agents running locally.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"N8ywWqpWCF02AGHcZxAV","title":"Ockam","pathname":"/warpstream/reference/integrations/ockam","siteSpaceId":"sitesp_1YOZF","description":"Instructions on integrating WarpStream with Ockam.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"9xPtQwX67WZBPTJvfM1R","title":"OpenTelemetry Collector","pathname":"/warpstream/reference/integrations/opentelemetry-collector","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to connect the OpenTelemetry Collector to WarpStream using the Kafka exporter.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"d30FkG5obcn8HLItlY4z","title":"Parquet","pathname":"/warpstream/reference/integrations/sqlite","siteSpaceId":"sitesp_1YOZF","description":"Apache Parquet is an open-source, column-oriented data file format designed for efficient data storage and retrieval. It forms the backbone of many datalake and table format systems.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"XH58Jk2Ew0eHZBklWY11","title":"Quix Streams","pathname":"/warpstream/reference/integrations/quix-streams","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to use the Quix Streams Python library to read and aggregate data from WarpStream and ingest the aggregations into a local DuckDB database for offline querying.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"ezomu6pYkVgKMl8nyZFs","title":"Railway","pathname":"/warpstream/reference/integrations/railway","siteSpaceId":"sitesp_1YOZF","description":"Instructions on how to deploy the WarpStream Agents to Railway.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"N5YhgqJjNYSqkpB1SeqH","title":"Redpanda Console","pathname":"/warpstream/reference/integrations/redpanda-console","siteSpaceId":"sitesp_1YOZF","description":"Redpanda Console is a web application that helps you manage and debug your Kafka workloads, as well as Kafka protocol-compatible systems such as Redpanda and WarpStream.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"KdSNBaxChnw1zorMRYS2","title":"RisingWave","pathname":"/warpstream/reference/integrations/use-warpstream-with-risingwave","siteSpaceId":"sitesp_1YOZF","description":"Instructions on how to use WarpStream with RisingWave.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"n3sFswDAQ6kKSGT5W68u","title":"Rockset","pathname":"/warpstream/reference/integrations/rockset","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate WarpStream with Rockset, ingest data into Rockset from WarpStream, and query the data in Rockset.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"kc79Ytew4AfckrEOaUBa","title":"ShadowTraffic","pathname":"/warpstream/reference/integrations/shadowtraffic","siteSpaceId":"sitesp_1YOZF","description":"ShadowTraffic is a containerized service for declaratively generating data, packed with knobs to perfectly mimic your production traffic to Kafka-compatible, and other destinations.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"RRZjEsBDxTSDgMyvgX8F","title":"SQLite","pathname":"/warpstream/reference/integrations/sqlite-1","siteSpaceId":"sitesp_1YOZF","description":"SQLite is an open-source, embedded, serverless RDBMS that is popular for its small size and ease of use.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"PNToMa726xbuBtLCbQKN","title":"Streambased","pathname":"/warpstream/reference/integrations/streambased","siteSpaceId":"sitesp_1YOZF","description":"Instructions on integrating WarpStream with Streambased.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"GnhdJY5NGeNLewI6AlaR","title":"Streamlit","pathname":"/warpstream/reference/integrations/streamlit","siteSpaceId":"sitesp_1YOZF","description":"Streamlit is a Python library that enables the simple creation of web apps.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"HFoVmhGHI9LfJcVh3lWs","title":"Timeplus","pathname":"/warpstream/reference/integrations/timeplus","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate WarpStream with Timeplus, to perform SQL commands on a data stream to perform queries, transformations and ETL.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"r6pUN6RwadjsIpL7oXea","title":"Tinybird","pathname":"/warpstream/reference/integrations/tinybird","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate WarpStream with Tinybird, ingest data into Tinybird from WarpStream, and then create an API endpoint for your applications to access the result set.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"MkqzfiEw2nrlYCmTlNEv","title":"Upsolver","pathname":"/warpstream/reference/integrations/upsolver","siteSpaceId":"sitesp_1YOZF","description":"This page describes how to integrate WarpStream with Upsolver, ingest data into Upsolver from WarpStream, then process and write the data to one of the available targets in Upsolver.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"},{"label":"Integrations"}]},{"id":"b7wScdm50Ocq24dlod9C","title":"Dedicated Control Plane Cells and Release Windows","pathname":"/warpstream/reference/dedicated-control-plane-cells-and-release-windows","siteSpaceId":"sitesp_1YOZF","description":"This page explains how WarpStream's dedicated control plane cells work, along with support for custom release windows.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"NabMOAtohwmbE7GHmZwi","title":"Control Plane Private Connectivity","pathname":"/warpstream/reference/control-plane-private-connectivity","siteSpaceId":"sitesp_1YOZF","description":"","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]},{"id":"KAwmLcj9a6cd6QsVpg5y","title":"Deprecation Policy","pathname":"/warpstream/reference/deprecation-policy","siteSpaceId":"sitesp_1YOZF","description":"This page describes our policy in the event of removal of customer-usable functionality from WarpStream services.","breadcrumbs":[{"label":"WarpStream"},{"label":"Reference"}]}]}