# Streamkap Docs ## Docs - [Agents](https://docs.streamkap.com/agents.md): Use AI agents to monitor, manage, and build on top of your Streamkap CDC infrastructure. - [Alerts](https://docs.streamkap.com/alerts.md): Monitor and receive real-time notifications for pipeline and connector events - [AlloyDB](https://docs.streamkap.com/alloydb.md): AlloyDB Change Data Capture Setup on Google Cloud with Streamkap - [Amazon RDS Aurora MySQL](https://docs.streamkap.com/amazon-rds-aurora-mysql.md): MySQL Change Data Capture Setup on Amazon RDS Aurora with Streamkap - [Amazon RDS Aurora PostgreSQL](https://docs.streamkap.com/amazon-rds-aurora-postgresql.md): PostgreSQL Change Data Capture Setup on Amazon RDS Aurora with Streamkap - [Amazon RDS MariaDB](https://docs.streamkap.com/amazon-rds-mariadb.md): MariaDB Change Data Capture Setup on Amazon RDS with Streamkap - [Amazon RDS MySQL](https://docs.streamkap.com/amazon-rds-mysql.md): MySQL Change Data Capture Setup on Amazon RDS with Streamkap - [Amazon RDS Oracle](https://docs.streamkap.com/amazon-rds-oracle.md): Oracle Change Data Capture Setup on Amazon RDS with Streamkap - [Amazon RDS PostgreSQL Serverless](https://docs.streamkap.com/amazon-rds-postgresql-serverless.md): PostgreSQL Change Data Capture Setup on Amazon RDS PostgreSQL Serverless with Streamkap - [SQL Server on Amazon RDS](https://docs.streamkap.com/amazon-rds-sql-server.md): SQL Server Change Data Capture on Amazon RDS with Streamkap - [Apache Iceberg (Generic)](https://docs.streamkap.com/apache-iceberg.md) - [Overview](https://docs.streamkap.com/api.md): Programmatic access to Streamkap via REST API, CLI, MCP, and Terraform. - [API Quickstart](https://docs.streamkap.com/api-quickstart.md): Get started with the Streamkap REST API: authentication, common workflows, and best practices. - [Delete Subscriber Credentials](https://docs.streamkap.com/api-reference/alerts/delete-subscriber-credentials.md) - [Get Subscriber Preferences](https://docs.streamkap.com/api-reference/alerts/get-subscriber-preferences.md) - [Get Subscribers](https://docs.streamkap.com/api-reference/alerts/get-subscribers.md) - [Summarise Alert](https://docs.streamkap.com/api-reference/alerts/summarise-alert.md): Generate AI-powered summary for an alert. - [Update Subscriber Credentials](https://docs.streamkap.com/api-reference/alerts/update-subscriber-credentials.md) - [Update Subscribers](https://docs.streamkap.com/api-reference/alerts/update-subscribers.md) - [Access Token](https://docs.streamkap.com/api-reference/authentication/access-token.md): Exchange credentials for a JWT access token. - [Create Client Credential](https://docs.streamkap.com/api-reference/authentication/create-client-credential.md) - [Delete Client Credential](https://docs.streamkap.com/api-reference/authentication/delete-client-credential.md) - [Get Mcp Tools](https://docs.streamkap.com/api-reference/authentication/get-mcp-tools.md): List all available MCP tools with profile membership. Fetches live from MCP server. - [Get Permissions](https://docs.streamkap.com/api-reference/authentication/get-permissions.md) - [Get Roles](https://docs.streamkap.com/api-reference/authentication/get-roles.md) - [List Client Credentials](https://docs.streamkap.com/api-reference/authentication/list-client-credentials.md) - [Refresh Access Token](https://docs.streamkap.com/api-reference/authentication/refresh-access-token.md): Refresh access token. - [Update Client Credential](https://docs.streamkap.com/api-reference/authentication/update-client-credential.md) - [Whoami](https://docs.streamkap.com/api-reference/authentication/whoami.md): Return the caller's verified identity: tenant, service, and credential linkage. - [Cancel Scale Operation](https://docs.streamkap.com/api-reference/cluster-scaling/cancel-scale-operation.md): Request cancellation. Controller checks between steps and stops if cancelled. - [Get Cluster Status](https://docs.streamkap.com/api-reference/cluster-scaling/get-cluster-status.md): Get current cluster status by fetching live state from EKS + K8s. - [Get Scale Operation Status](https://docs.streamkap.com/api-reference/cluster-scaling/get-scale-operation-status.md): Get the current status of a scaling operation. Frontend polls this every 5 seconds. - [Is Cluster Scaling Enabled](https://docs.streamkap.com/api-reference/cluster-scaling/is-cluster-scaling-enabled.md): Lightweight check: returns whether the current service has a cluster_config record. - [Scale Cluster](https://docs.streamkap.com/api-reference/cluster-scaling/scale-cluster.md): Create a scaling operation record. The skap-scaling controller picks it up and executes. - [Get Consumer Group Detail](https://docs.streamkap.com/api-reference/consumer-groups/get-consumer-group-detail.md): Get detailed information about a specific consumer group. - [List Consumer Groups](https://docs.streamkap.com/api-reference/consumer-groups/list-consumer-groups.md): List consumer groups for the tenant with pagination. Excludes internal/system consumer groups. - [Reset Consumer Group Offsets](https://docs.streamkap.com/api-reference/consumer-groups/reset-consumer-group-offsets.md): Reset offsets for selected topics in a consumer group. - [Batch fetch topics for multiple entities](https://docs.streamkap.com/api-reference/dashboard/batch-fetch-topics-for-multiple-entities.md): Returns enriched topics grouped by entity ID. Use for polling refresh or expand-all when groups are already loaded. Accepts 1-100 entity IDs. - [Get dashboard health summary](https://docs.streamkap.com/api-reference/dashboard/get-dashboard-health-summary.md): Returns a high-level health overview including broken connectors, failed transforms, active snapshots, and topic health metrics. - [Get dashboard lineage groups](https://docs.streamkap.com/api-reference/dashboard/get-dashboard-lineage-groups.md): Returns lineage groups (sources, destinations, or transforms) with aggregated metrics. Use the group_by parameter to select the grouping dimension. - [Get dashboard lineage topics](https://docs.streamkap.com/api-reference/dashboard/get-dashboard-lineage-topics.md): Returns detailed topic-level lineage information including source, transforms, destinations, and per-topic metrics. Supports filtering and pagination. - [Get latest QA row counts for topics](https://docs.streamkap.com/api-reference/dashboard/get-latest-qa-row-counts-for-topics.md): Returns per-topic source_count, destination_count, and shard_counts from the most recent metrics_qa collection. Accepts lineage topic names (e.g., source_XXX.demo.shard1.Orders) and matches against metrics_qa topic_ids. - [Get Organisation Statistics](https://docs.streamkap.com/api-reference/dashboard/get-organisation-statistics.md): Fetch organisation statistics for the authenticated user with proper permissions. - [Bulk Delete Destinations](https://docs.streamkap.com/api-reference/destinations/bulk-delete-destinations.md): Delete multiple destinations in parallel. Supports two modes: 1. Explicit IDs: Pass a list of destination IDs to delete 2. Select all: Set select_all=true with optional filters to delete all matching destinations - [Bulk Reset Destinations](https://docs.streamkap.com/api-reference/destinations/bulk-reset-destinations.md): Reset multiple destinations in parallel (stops, deletes offsets, resumes). Supports two modes: 1. Explicit IDs: Pass a list of destination IDs 2. Select all: Set select_all=true with optional filters - [Bulk Resume Destinations](https://docs.streamkap.com/api-reference/destinations/bulk-resume-destinations.md): Resume multiple destinations in parallel. Supports two modes: 1. Explicit IDs: Pass a list of destination IDs 2. Select all: Set select_all=true with optional filters - [Bulk Stop Destinations](https://docs.streamkap.com/api-reference/destinations/bulk-stop-destinations.md): Stop multiple destinations in parallel. Supports two modes: 1. Explicit IDs: Pass a list of destination IDs 2. Select all: Set select_all=true with optional filters - [Create New Destination](https://docs.streamkap.com/api-reference/destinations/create-new-destination.md): Create a new destination connector. - [Delete Existing Destination](https://docs.streamkap.com/api-reference/destinations/delete-existing-destination.md) - [Deploy Destination](https://docs.streamkap.com/api-reference/destinations/deploy-destination.md): Deploy a PENDING destination, transitioning it to ACTIVE. - [Destination Configs](https://docs.streamkap.com/api-reference/destinations/destination-configs.md) - [Destination Invite](https://docs.streamkap.com/api-reference/destinations/destination-invite.md) - [Get Destination](https://docs.streamkap.com/api-reference/destinations/get-destination.md) - [Get Destination Config History](https://docs.streamkap.com/api-reference/destinations/get-destination-config-history.md): Retrieve configuration change history for a destination with AI-generated summaries. - [Get Destination Configuration](https://docs.streamkap.com/api-reference/destinations/get-destination-configuration.md) - [Get destination metrics (POST)](https://docs.streamkap.com/api-reference/destinations/get-destination-metrics-post.md): POST alternative for GET /destinations/metrics. Use when URL length limits are exceeded (e.g., 100+ IDs). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Get Destinations](https://docs.streamkap.com/api-reference/destinations/get-destinations.md) - [Get Destinations Connectors](https://docs.streamkap.com/api-reference/destinations/get-destinations-connectors.md): List available destination connector types and their configuration schemas. - [Get Metrics For Destination](https://docs.streamkap.com/api-reference/destinations/get-metrics-for-destination.md): Retrieve metrics for a specific destination based on the provided parameters. - [Get Metrics For Destinations](https://docs.streamkap.com/api-reference/destinations/get-metrics-for-destinations.md) - [Get Sample Scripts For Destinations](https://docs.streamkap.com/api-reference/destinations/get-sample-scripts-for-destinations.md) - [List All Destinations Brief](https://docs.streamkap.com/api-reference/destinations/list-all-destinations-brief.md) - [Pause Existing Destination](https://docs.streamkap.com/api-reference/destinations/pause-existing-destination.md) - [Reset Existing Destination](https://docs.streamkap.com/api-reference/destinations/reset-existing-destination.md): Reset a destination connector by stopping it, deleting offsets, and resuming it. This will treat the connector as brand new and start consuming from the beginning. - [Restart Destination Task Api](https://docs.streamkap.com/api-reference/destinations/restart-destination-task-api.md) - [Restart Existing Destination](https://docs.streamkap.com/api-reference/destinations/restart-existing-destination.md) - [Resume Existing Destination](https://docs.streamkap.com/api-reference/destinations/resume-existing-destination.md) - [Search destinations (POST)](https://docs.streamkap.com/api-reference/destinations/search-destinations-post.md): POST alternative for GET /destinations. Use when URL length limits are exceeded (e.g., many filter values). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Stop Existing Destination](https://docs.streamkap.com/api-reference/destinations/stop-existing-destination.md) - [Update Bulk Destinations](https://docs.streamkap.com/api-reference/destinations/update-bulk-destinations.md): Update tags for multiple destinations in bulk. - [Update Existing Destination](https://docs.streamkap.com/api-reference/destinations/update-existing-destination.md): Update an existing destination connector. - [Cancel Flink Job](https://docs.streamkap.com/api-reference/flink-jobs/cancel-flink-job.md): Cancel a running Flink job. - [Delete Flink Job](https://docs.streamkap.com/api-reference/flink-jobs/delete-flink-job.md): Soft-delete a Flink job (cancels it first if running). - [Deploy Jar Job](https://docs.streamkap.com/api-reference/flink-jobs/deploy-jar-job.md): Deploy a JAR-based Flink job. - [Deploy Pyflink Job](https://docs.streamkap.com/api-reference/flink-jobs/deploy-pyflink-job.md): Deploy a PyFlink job. - [Get Flink Job](https://docs.streamkap.com/api-reference/flink-jobs/get-flink-job.md): Get a Flink job with live status from Flink REST. - [Get Flink Job Status](https://docs.streamkap.com/api-reference/flink-jobs/get-flink-job-status.md): Get lightweight status for a Flink job (DB + live Flink state only). - [List Flink Jobs](https://docs.streamkap.com/api-reference/flink-jobs/list-flink-jobs.md): List all Flink jobs for the current tenant/service. - [Restart Flink Job](https://docs.streamkap.com/api-reference/flink-jobs/restart-flink-job.md): Restart a cancelled or failed Flink job. - [Create New Kafka User](https://docs.streamkap.com/api-reference/kafka-access/create-new-kafka-user.md) - [Delete Kafka User](https://docs.streamkap.com/api-reference/kafka-access/delete-kafka-user.md): Delete a Kafka user (and its proxy, ACLs, SCRAM credentials). - [List Kafka Users](https://docs.streamkap.com/api-reference/kafka-access/list-kafka-users.md) - [Update Kafka User](https://docs.streamkap.com/api-reference/kafka-access/update-kafka-user.md) - [Get Logs](https://docs.streamkap.com/api-reference/logs/get-logs.md): Get logs - [Get Logs Count](https://docs.streamkap.com/api-reference/logs/get-logs-count.md): Get count of new logs since a specific timestamp. - [Get Logs Histogram](https://docs.streamkap.com/api-reference/logs/get-logs-histogram.md): Get histogram data for log counts bucketed by time. - [Summarise Log](https://docs.streamkap.com/api-reference/logs/summarise-log.md): Generate and store a structured summary for a single log entry. - [Bulk Delete Pipelines](https://docs.streamkap.com/api-reference/pipelines/bulk-delete-pipelines.md): Delete multiple pipelines in parallel. - [Create New Pipeline](https://docs.streamkap.com/api-reference/pipelines/create-new-pipeline.md) - [Delete Existing Pipeline](https://docs.streamkap.com/api-reference/pipelines/delete-existing-pipeline.md) - [Get Logs For Pipelines](https://docs.streamkap.com/api-reference/pipelines/get-logs-for-pipelines.md) - [Get Metrics For Pipeline](https://docs.streamkap.com/api-reference/pipelines/get-metrics-for-pipeline.md): Retrieve metrics for a specific pipeline based on the provided parameters. - [Get Metrics For Pipelines](https://docs.streamkap.com/api-reference/pipelines/get-metrics-for-pipelines.md) - [Get Pipeline](https://docs.streamkap.com/api-reference/pipelines/get-pipeline.md) - [Get pipeline metrics (POST)](https://docs.streamkap.com/api-reference/pipelines/get-pipeline-metrics-post.md): POST alternative for GET /pipelines/metrics. Use when URL length limits are exceeded (e.g., 100+ IDs). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Get Pipelines](https://docs.streamkap.com/api-reference/pipelines/get-pipelines.md) - [List All Pipelines Brief](https://docs.streamkap.com/api-reference/pipelines/list-all-pipelines-brief.md) - [Search pipelines (POST)](https://docs.streamkap.com/api-reference/pipelines/search-pipelines-post.md): POST alternative for GET /pipelines. Use when URL length limits are exceeded (e.g., many filter values). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Update Bulk Pipelines](https://docs.streamkap.com/api-reference/pipelines/update-bulk-pipelines.md): Update tags for multiple pipelines in bulk. - [Update Existing Pipeline](https://docs.streamkap.com/api-reference/pipelines/update-existing-pipeline.md) - [Create Project Key](https://docs.streamkap.com/api-reference/project-keys/create-project-key.md): Create a Project Key with API credentials and optional Kafka access. - [Delete Project Key](https://docs.streamkap.com/api-reference/project-keys/delete-project-key.md): Delete a Project Key and all constituent resources (API credential, Kafka user, K8s proxy, ACLs). - [Get Project Key](https://docs.streamkap.com/api-reference/project-keys/get-project-key.md): Get Project Key detail including Kafka ACLs and whitelist IPs for edit modal hydration. - [Get Project Key Mcp Config](https://docs.streamkap.com/api-reference/project-keys/get-project-key-mcp-config.md): Returns authoritative MCP tool scoping config for server-side enforcement. - [List Project Keys](https://docs.streamkap.com/api-reference/project-keys/list-project-keys.md): List all Project Keys for the current tenant. Returns summaries with no secrets. - [Update Project Key](https://docs.streamkap.com/api-reference/project-keys/update-project-key.md): Update a Project Key's name, description, roles, tool scoping, or Kafka ACLs. - [Get Schema By Id](https://docs.streamkap.com/api-reference/schema-registry/get-schema-by-id.md): Get a schema by its global ID. - [Get Schema By Version](https://docs.streamkap.com/api-reference/schema-registry/get-schema-by-version.md): Get a specific schema version for a subject. Version can be a number or 'latest'. - [List Schema Subjects](https://docs.streamkap.com/api-reference/schema-registry/list-schema-subjects.md): List schema subjects for the tenant with pagination. Excludes internal subjects. Optional: include_metadata=true to get latest version info in a single request. - [List Subject Versions](https://docs.streamkap.com/api-reference/schema-registry/list-subject-versions.md): List all version numbers for a specific schema subject. - [Get All Service Metadata](https://docs.streamkap.com/api-reference/services/get-all-service-metadata.md): Fetch metadata for all tenant services. - [Switch](https://docs.streamkap.com/api-reference/services/switch.md): Switch service for the tenant. - [Bulk Delete Sources](https://docs.streamkap.com/api-reference/sources/bulk-delete-sources.md): Delete multiple sources in parallel. Supports two modes: 1. Explicit IDs: Pass a list of source IDs to delete 2. Select all: Set select_all=true with optional filters to delete all matching sources - [Bulk Execute Snapshot Sources](https://docs.streamkap.com/api-reference/sources/bulk-execute-snapshot-sources.md): Execute snapshot on multiple sources in parallel. - [Bulk Reset Sources](https://docs.streamkap.com/api-reference/sources/bulk-reset-sources.md): Reset multiple sources in parallel (stops, deletes offsets, resumes). Supports two modes: 1. Explicit IDs: Pass a list of source IDs 2. Select all: Set select_all=true with optional filters - [Bulk Resume Sources](https://docs.streamkap.com/api-reference/sources/bulk-resume-sources.md): Resume multiple sources in parallel. Supports two modes: 1. Explicit IDs: Pass a list of source IDs 2. Select all: Set select_all=true with optional filters - [Bulk Stop Snapshot Sources](https://docs.streamkap.com/api-reference/sources/bulk-stop-snapshot-sources.md): Stop snapshot on multiple sources in parallel. - [Bulk Stop Sources](https://docs.streamkap.com/api-reference/sources/bulk-stop-sources.md): Stop multiple sources in parallel. Supports two modes: 1. Explicit IDs: Pass a list of source IDs 2. Select all: Set select_all=true with optional filters - [Cancel Snapshot](https://docs.streamkap.com/api-reference/sources/cancel-snapshot.md): Cancel an in-progress snapshot with automatic type detection. - [Create New Source](https://docs.streamkap.com/api-reference/sources/create-new-source.md): Create a new source connector. - [Delete Existing Source](https://docs.streamkap.com/api-reference/sources/delete-existing-source.md) - [Deploy Source](https://docs.streamkap.com/api-reference/sources/deploy-source.md): Deploy a PENDING source, transitioning it to ACTIVE. - [Execute Blocking Snapshot](https://docs.streamkap.com/api-reference/sources/execute-blocking-snapshot.md): Execute a blocking snapshot for the specified source. - [Execute Incremental Snapshot](https://docs.streamkap.com/api-reference/sources/execute-incremental-snapshot.md) - [Execute Snapshot](https://docs.streamkap.com/api-reference/sources/execute-snapshot.md): Execute a snapshot for the specified source with configurable snapshot type. - [Get Metrics For Source](https://docs.streamkap.com/api-reference/sources/get-metrics-for-source.md): Retrieve metrics for a specific source based on the provided parameters. - [Get Metrics For Sources](https://docs.streamkap.com/api-reference/sources/get-metrics-for-sources.md) - [Get Source](https://docs.streamkap.com/api-reference/sources/get-source.md) - [Get Source Config History](https://docs.streamkap.com/api-reference/sources/get-source-config-history.md): Retrieve configuration change history for a source with AI-generated summaries. - [Get Source Configuration](https://docs.streamkap.com/api-reference/sources/get-source-configuration.md) - [Get source metrics (POST)](https://docs.streamkap.com/api-reference/sources/get-source-metrics-post.md): POST alternative for GET /sources/metrics. Use when URL length limits are exceeded (e.g., 100+ IDs). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Get Sources](https://docs.streamkap.com/api-reference/sources/get-sources.md) - [Get Sources Connectors](https://docs.streamkap.com/api-reference/sources/get-sources-connectors.md): List available source connector types and their configuration schemas. - [List All Sources Brief](https://docs.streamkap.com/api-reference/sources/list-all-sources-brief.md) - [Pause Existing Source](https://docs.streamkap.com/api-reference/sources/pause-existing-source.md) - [Reset Existing Source](https://docs.streamkap.com/api-reference/sources/reset-existing-source.md): Reset a source connector by stopping it, deleting offsets, and resuming it. This will treat the connector as brand new and perform an initial snapshot. - [Restart Existing Source](https://docs.streamkap.com/api-reference/sources/restart-existing-source.md) - [Restart Source Task Api](https://docs.streamkap.com/api-reference/sources/restart-source-task-api.md) - [Resume Existing Source](https://docs.streamkap.com/api-reference/sources/resume-existing-source.md) - [Search sources (POST)](https://docs.streamkap.com/api-reference/sources/search-sources-post.md): POST alternative for GET /sources. Use when URL length limits are exceeded (e.g., many filter values). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Source Configs](https://docs.streamkap.com/api-reference/sources/source-configs.md) - [Source Invite](https://docs.streamkap.com/api-reference/sources/source-invite.md) - [Stop Blocking Snapshot](https://docs.streamkap.com/api-reference/sources/stop-blocking-snapshot.md): Stop a blocking snapshot for the specified source. - [Stop Existing Source](https://docs.streamkap.com/api-reference/sources/stop-existing-source.md) - [Stop Incremental Snapshot](https://docs.streamkap.com/api-reference/sources/stop-incremental-snapshot.md) - [Update Bulk Sources](https://docs.streamkap.com/api-reference/sources/update-bulk-sources.md): Update tags for multiple sources in bulk. - [Update Existing Source](https://docs.streamkap.com/api-reference/sources/update-existing-source.md): Update an existing source connector. - [Create Tag](https://docs.streamkap.com/api-reference/tags/create-tag.md): Create a new tag. - [Delete Tag](https://docs.streamkap.com/api-reference/tags/delete-tag.md): Delete a tag. - [Get Tags By Type](https://docs.streamkap.com/api-reference/tags/get-tags-by-type.md): Get tags by tag_type. - [Get Tags For Specific Tenant](https://docs.streamkap.com/api-reference/tags/get-tags-for-specific-tenant.md): Get tags by tag_ids and tag_type. - [Search tags (POST)](https://docs.streamkap.com/api-reference/tags/search-tags-post.md): POST alternative for GET /tags. Use when URL length limits are exceeded (e.g., 100+ tag IDs). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Update Tag](https://docs.streamkap.com/api-reference/tags/update-tag.md): Update a tag. - [Bulk Snapshot Topics](https://docs.streamkap.com/api-reference/topics/bulk-snapshot-topics.md): Execute snapshot for selected topics, grouped by their source connector. - [Bulk Stop Snapshot Topics](https://docs.streamkap.com/api-reference/topics/bulk-stop-snapshot-topics.md): Stop snapshot for sources identified by the selected topics. - [Create a new Kafka topic](https://docs.streamkap.com/api-reference/topics/create-a-new-kafka-topic.md) - [Delete Topic Api](https://docs.streamkap.com/api-reference/topics/delete-topic-api.md) - [Get a single topic message value](https://docs.streamkap.com/api-reference/topics/get-a-single-topic-message-value.md): Fetch the full value of a single topic message on demand (e.g. for oversized messages). - [Get comprehensive topic information](https://docs.streamkap.com/api-reference/topics/get-comprehensive-topic-information.md) - [Get topic configurations](https://docs.streamkap.com/api-reference/topics/get-topic-configurations.md) - [Get topic messages](https://docs.streamkap.com/api-reference/topics/get-topic-messages.md) - [Get topic metrics](https://docs.streamkap.com/api-reference/topics/get-topic-metrics.md) - [Get topic statistics](https://docs.streamkap.com/api-reference/topics/get-topic-statistics.md) - [List all topics](https://docs.streamkap.com/api-reference/topics/list-all-topics.md) - [List topics grouped by connector/entity](https://docs.streamkap.com/api-reference/topics/list-topics-grouped-by-connectorentity.md): Get topics grouped by entity_id (connector instances) with nested pagination. - [Search topics (POST)](https://docs.streamkap.com/api-reference/topics/search-topics-post.md): POST alternative for GET /topics/details. Use when URL length limits are exceeded (e.g., 100+ entity IDs). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Table Metrics](https://docs.streamkap.com/api-reference/topics/table-metrics.md) - [Update Bulk Topics](https://docs.streamkap.com/api-reference/topics/update-bulk-topics.md): Update tags for multiple topics in bulk. - [Update Topic Api](https://docs.streamkap.com/api-reference/topics/update-topic-api.md) - [Bulk Clone Transforms](https://docs.streamkap.com/api-reference/transforms/bulk-clone-transforms.md): Clone multiple transforms with new names in parallel. Supports two modes: 1. Explicit items: Provide list of items with id and name for each clone 2. Select all: Set select_all=true with optional filters and name_suffix - [Bulk Delete Transforms](https://docs.streamkap.com/api-reference/transforms/bulk-delete-transforms.md): Delete multiple transforms in parallel. Supports two modes: 1. Explicit IDs: Pass a list of transform IDs to delete 2. Select all: Set select_all=true with optional filters to delete all matching transforms - [Clear Output Topics](https://docs.streamkap.com/api-reference/transforms/clear-output-topics.md) - [Clone Transform](https://docs.streamkap.com/api-reference/transforms/clone-transform.md) - [Create New Transform](https://docs.streamkap.com/api-reference/transforms/create-new-transform.md) - [Create New Transform With Full Process](https://docs.streamkap.com/api-reference/transforms/create-new-transform-with-full-process.md) - [Delete Existing Transform](https://docs.streamkap.com/api-reference/transforms/delete-existing-transform.md) - [Deploy Job Live](https://docs.streamkap.com/api-reference/transforms/deploy-job-live.md) - [Deploy Job Preview](https://docs.streamkap.com/api-reference/transforms/deploy-job-preview.md) - [Get Errors Transform](https://docs.streamkap.com/api-reference/transforms/get-errors-transform.md) - [Get Full Transforms](https://docs.streamkap.com/api-reference/transforms/get-full-transforms.md) - [Get Full Transforms With Id](https://docs.streamkap.com/api-reference/transforms/get-full-transforms-with-id.md) - [Get Jobs Status](https://docs.streamkap.com/api-reference/transforms/get-jobs-status.md) - [Get Output Topics For Transform](https://docs.streamkap.com/api-reference/transforms/get-output-topics-for-transform.md) - [Get Topics For Pattern](https://docs.streamkap.com/api-reference/transforms/get-topics-for-pattern.md) - [Get Transform Checkpoints](https://docs.streamkap.com/api-reference/transforms/get-transform-checkpoints.md): Get checkpoint statistics and state size information for a transform job. - [Get Transform Configs](https://docs.streamkap.com/api-reference/transforms/get-transform-configs.md) - [Get Transform Details](https://docs.streamkap.com/api-reference/transforms/get-transform-details.md) - [Get Transform Dlq Errors](https://docs.streamkap.com/api-reference/transforms/get-transform-dlq-errors.md): Get DLQ errors for transform - retrieves the first DLQ error from the topic and shows: timestamp, error message, message offset, link to the DLQ topic. - [Get Transform Metrics](https://docs.streamkap.com/api-reference/transforms/get-transform-metrics.md) - [Get Transforms Implementation Details](https://docs.streamkap.com/api-reference/transforms/get-transforms-implementation-details.md) - [List All Transforms Brief](https://docs.streamkap.com/api-reference/transforms/list-all-transforms-brief.md) - [Put Transforms Implementation Details](https://docs.streamkap.com/api-reference/transforms/put-transforms-implementation-details.md) - [Run Unit Tests](https://docs.streamkap.com/api-reference/transforms/run-unit-tests.md) - [Search transforms (POST)](https://docs.streamkap.com/api-reference/transforms/search-transforms-post.md): POST alternative for GET /transforms. Use when URL length limits are exceeded (e.g., 100+ tag IDs). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Set Input Output Topics](https://docs.streamkap.com/api-reference/transforms/set-input-output-topics.md) - [Update Bulk Transforms](https://docs.streamkap.com/api-reference/transforms/update-bulk-transforms.md): Update tags for multiple transforms in bulk. - [Update Transform](https://docs.streamkap.com/api-reference/transforms/update-transform.md) - [Get Usage Export](https://docs.streamkap.com/api-reference/usage/get-usage-export.md): Export usage metrics as a CSV. - [Get Usage Metrics](https://docs.streamkap.com/api-reference/usage/get-usage-metrics.md): Fetch detailed usage metrics for the organisation. - [Get usage metrics (POST)](https://docs.streamkap.com/api-reference/usage/get-usage-metrics-post.md): POST alternative for GET /billing/usage/metrics. Use when URL length limits are exceeded (e.g., 100+ tenant IDs). Supports both query parameters and request body. Body parameters take precedence over query parameters. - [Get Usage Summary](https://docs.streamkap.com/api-reference/usage/get-usage-summary.md): Fetch usage summary for the billing page. - [API Tokens](https://docs.streamkap.com/api-tokens.md): How to generate and manage your Streamkap API tokens - [Audit Logs](https://docs.streamkap.com/audit-logs.md): Full audit logs available for security compliance - [AWS Cross-Account IAM Setup](https://docs.streamkap.com/aws-cross-account-iam.md): Configure IAM roles for Streamkap to securely access your AWS resources using cross-account role assumption. - [AWS Glue](https://docs.streamkap.com/aws-glue.md): Stream data into AWS Glue - [AWS BYOC](https://docs.streamkap.com/aws-kafka-byoc.md) - [AWS Private Link](https://docs.streamkap.com/aws-private-link.md) - [Azure Blob Storage](https://docs.streamkap.com/azure-blob-storage.md) - [Azure BYOC](https://docs.streamkap.com/azure-byoc.md) - [Azure MySQL Database](https://docs.streamkap.com/azure-mysql-database.md): MySQL Change Data Capture Setup on Azure MySQL Database with Streamkap - [Batch vs Streaming](https://docs.streamkap.com/batch-vs-streaming-data.md) - [Overview](https://docs.streamkap.com/bring-your-own-cloud-byoc.md): Streamkap Kafka/Flink BYOC on AWS, GCP and Azure - [CLI](https://docs.streamkap.com/cli.md): Manage Streamkap pipelines, sources, destinations, and more from the command line. - [ClickHouse Cloud](https://docs.streamkap.com/clickhouse.md): ClickHouse Cloud destination configuration for Streamkap CDC - [CockroachDB](https://docs.streamkap.com/cockroachdb.md): Stream data into CockroachDB - [Overview](https://docs.streamkap.com/concepts.md): Key concepts about real-time data processing and Streamkap's architecture - [Overview](https://docs.streamkap.com/connection-options.md): Network connectivity options for connecting Streamkap to your sources and destinations - [Database Connectivity SSL Certificate Management Guide](https://docs.streamkap.com/connector-security-ssl.md): This guide can help you identify SSL certificate details and encryption levels for database instances and how to update them to use stronger encryption. - [Consumer Groups](https://docs.streamkap.com/consumer-groups.md): Monitor and manage consumer groups, track consumer lag, and manage offset positions - [Creating Final State Tables](https://docs.streamkap.com/creating-final-state-tables-from-insertsappend.md): How to create final state tables from append (or insert) only destinations. - [Data Encoding & Character Sets](https://docs.streamkap.com/data-encoding.md): How Streamkap handles character encoding, binary data, and charset configuration in CDC pipelines. - [Database Upgrade Guide](https://docs.streamkap.com/database-upgrade-guide.md): How to maintain CDC pipelines during source database version upgrades - [Databricks Delta Lake](https://docs.streamkap.com/databricks-delta-lake.md) - [Db2 (Generic)](https://docs.streamkap.com/db2-generic.md) - [Deployment Options](https://docs.streamkap.com/deployment-options.md): Choose between Streamkap Cloud and Bring Your Own Cloud (BYOC) deployment models - [Destinations](https://docs.streamkap.com/destinations.md) - [Disaster Recovery & Failover](https://docs.streamkap.com/disaster-recovery.md): Handling outages and recovery procedures for Streamkap CDC pipelines across sources, destinations, and platform components. - [Dead Letter Queue (DLQ)](https://docs.streamkap.com/dlq-operations.md): Monitor, inspect, and resolve messages that failed processing in your Streamkap pipelines. - [DocumentDB](https://docs.streamkap.com/documentdb.md): DocumentDB Change Data Capture Setup with Streamkap - [DocumentDB Source FAQ](https://docs.streamkap.com/documentdb-source-faq.md) - [DynamoDB](https://docs.streamkap.com/dynamodb-source.md): DynamoDB Change Data Capture Setup with Streamkap - [Elasticsearch](https://docs.streamkap.com/elasticsearch.md): Elasticsearch Change Data Capture Setup with Streamkap - [Error Reference](https://docs.streamkap.com/error-reference.md): Consolidated lookup for common Streamkap errors, their causes, and resolution steps — organized by category for quick troubleshooting. - [Streamkap Docs](https://docs.streamkap.com/getting-started.md): Serverless, real-time data integration platform for streaming data sub-second from sources to destinations - [Overview](https://docs.streamkap.com/google-bigquery.md) - [Best Practices](https://docs.streamkap.com/google-bigquery-best-practices.md): How to keep costs low and queries running fast - [Google Cloud MySQL](https://docs.streamkap.com/google-cloud-mysql.md): MySQL Change Data Capture Setup on Google Cloud SQL with Streamkap - [Google Cloud SQL for PostgreSQL](https://docs.streamkap.com/google-cloud-sql-postgresql.md): PostgreSQL Change Data Capture Setup on Google Cloud SQL with Streamkap - [Heartbeat Configuration](https://docs.streamkap.com/heartbeat-configuration.md): Configure heartbeat tables to prevent change log retention issues on low-traffic databases. - [HTTP Sink](https://docs.streamkap.com/http-sink.md): Deliver Kafka topic records to an external HTTP endpoint - [Overview](https://docs.streamkap.com/ibm-db2.md) - [Overview](https://docs.streamkap.com/iceberg.md) - [Ingestion Modes](https://docs.streamkap.com/insertsupserts.md): Understand how Streamkap writes records to destinations: insert vs upsert behavior, primary keys, and delete handling. - [Kafka Access](https://docs.streamkap.com/kafka-access.md): Manage Kafka users, ACLs, and access control - [Kafka Direct](https://docs.streamkap.com/kafka-direct.md): Consume messages from an external Kafka cluster and stream them through Streamkap pipelines. - [Kafka (Push)](https://docs.streamkap.com/kafka-to-kafka.md): Replicate topics from Streamkap to another Kafka cluster - [Login](https://docs.streamkap.com/login.md): Sign in to your Streamkap account using various authentication methods - [Logs](https://docs.streamkap.com/logs.md): View and search system logs for troubleshooting pipelines and connectors - [Overview](https://docs.streamkap.com/mariadb.md): Streamkap supports syncing MariaDB in real-time using change data capture for: - [MariaDB (Generic)](https://docs.streamkap.com/mariadb-generic.md): MariaDB Change Data Capture Setup with Streamkap - [MCP Server](https://docs.streamkap.com/mcp-server.md): Connect AI agents to Streamkap to manage CDC pipelines, sources, destinations, and transforms via natural language. - [Metadata](https://docs.streamkap.com/metadata.md): Metadata columns added by Streamkap to destination tables - [Overview](https://docs.streamkap.com/mongodb.md): Streamkap supports syncing MongoDB in real-time using change data capture for: - [MongoDB (Generic)](https://docs.streamkap.com/mongodb-1.md) - [MongoDB Atlas](https://docs.streamkap.com/mongodb-atlas.md): MongoDB Atlas Change Data Capture Setup with Streamkap - [MongoDB Source FAQ](https://docs.streamkap.com/mongodb-source-faq.md) - [Monitoring The PostgreSQL WAL Log](https://docs.streamkap.com/monitoring-the-postgresql-wal-log.md): Guide to monitoring the PostgreSQL WAL Log - [Overview](https://docs.streamkap.com/motherduck.md) - [MotherDuck (Native)](https://docs.streamkap.com/motherduck-native.md): Stream data to MotherDuck from Streamkap using native jdbc driver - [MotherDuck (S3)](https://docs.streamkap.com/motherduck-s3.md): Stream data to MotherDuck from Streamkap using S3 as an intermediary - [Overview](https://docs.streamkap.com/mysql.md): Streamkap supports syncing MySQL in real-time using change data capture for: - [MySQL (Generic)](https://docs.streamkap.com/mysql-generic.md): MySQL Change Data Capture Setup with Streamkap - [MySQL Low Volume Log Rotation](https://docs.streamkap.com/mysql-low-volume-log-rotation.md): Set log rotation for low volume databases - [MySQL Source FAQ](https://docs.streamkap.com/mysql-source-faq.md): MySQL Source FAQ - [Neon](https://docs.streamkap.com/neon-destination.md): Stream data into Neon PostgreSQL - [Neon PostgreSQL](https://docs.streamkap.com/neon-postgresql-cdc.md): PostgreSQL Change Data Capture Setup on Neon with Streamkap - [Observability](https://docs.streamkap.com/observability.md): Monitor system health, data lineage, and record count accuracy across your Streamkap pipelines - [OpenID connect - IDP setup](https://docs.streamkap.com/openid-connect-idp-setup.md) - [OpenSearch](https://docs.streamkap.com/opensearch.md): Stream data from OpenSearch - [Overview](https://docs.streamkap.com/oracle.md): Streamkap supports syncing OracleDB in real-time using change data capture for: - [Oracle (Generic)](https://docs.streamkap.com/oracle-generic.md): Oracle Change Data Capture Setup with Streamkap - [Oracle Source FAQ](https://docs.streamkap.com/oracle-source-faq.md) - [Organisation Security](https://docs.streamkap.com/organisation-security.md): Configure organization-wide security policies and settings - [Parquet](https://docs.streamkap.com/parquet.md) - [Performance Tuning](https://docs.streamkap.com/performance-tuning.md): Optimize pipeline throughput and latency for your CDC workloads - [Personal Privacy & Security](https://docs.streamkap.com/personal-privacy-security.md): Manage your personal security settings including password, MFA, passkeys, and sessions - [Pipeline Recovery Procedures](https://docs.streamkap.com/pipeline-recovery.md): Troubleshoot and recover Streamkap pipelines using structured decision trees, step-by-step procedures, and scenario-based guidance. - [Pipelines](https://docs.streamkap.com/pipelines.md): Create and manage data pipelines connecting sources to destinations - [PlanetScale (Vitess)](https://docs.streamkap.com/planetscale.md): PlanetScale Change Data Capture Setup with Streamkap - [Overview](https://docs.streamkap.com/postgresql.md): Streamkap supports syncing PostgreSQL in real-time using change data capture for: - [Amazon RDS PostgreSQL](https://docs.streamkap.com/postgresql-on-amazon-rds.md): PostgreSQL Change Data Capture Setup on Amazon RDS with Streamkap - [Azure PostgreSQL](https://docs.streamkap.com/postgresql-on-azure-database.md): PostgreSQL Change Data Capture Setup on Azure with Streamkap - [PostgreSQL](https://docs.streamkap.com/postgresql-self-hosted.md): PostgreSQL Change Data Capture Setup with Streamkap - [PostgreSQL Source FAQ](https://docs.streamkap.com/postgresql-source-faq.md) - [Profile](https://docs.streamkap.com/profile.md): Manage your personal profile information in Streamkap - [Project Keys](https://docs.streamkap.com/project-keys.md): Create unified credentials that bundle API access, Kafka access, and MCP tool scoping into a single downloadable file. - [Projects](https://docs.streamkap.com/projects.md): Manage and switch between Streamkap projects across regions and environments - [Overview](https://docs.streamkap.com/r2.md) - [Kafka (Reading)](https://docs.streamkap.com/reading-from-kafka.md): Read directly from Kafka - [Overview](https://docs.streamkap.com/redis-destination.md): Stream data to Redis - [Redis Cloud](https://docs.streamkap.com/redis-destination-cloud.md): Stream data into Redis Cloud - [Redis (Generic)](https://docs.streamkap.com/redis-destination-generic.md): Stream data into Redis - [Overview](https://docs.streamkap.com/redis-source.md): Stream data from Redis - [Redis Source](https://docs.streamkap.com/redis-source-generic.md): Redis Change Data Capture Setup with Streamkap - [Redshift](https://docs.streamkap.com/redshift.md): Stream data into Redshift - [Regex Support for >100k Tables](https://docs.streamkap.com/regex-support.md): Use regex patterns in Source schema configuration to merge related tables into logical topics for multi-tenant, sharded, or cell-based architectures. - [Overview](https://docs.streamkap.com/s3.md): Change Data Capture using S3 with Streamkap - [S3 Source](https://docs.streamkap.com/s3-source.md): Stream files from Amazon S3 into Streamkap - [SAML IDP Setup](https://docs.streamkap.com/saml-idp-setup.md): Configure SAML 2.0 identity provider integration for Streamkap single sign-on. - [Schema Evolution](https://docs.streamkap.com/schema-evolution-support.md): How Streamkap handles schema changes between source and destination, including column name case sensitivity across databases. - [Schema Registry](https://docs.streamkap.com/schema-registry.md): Browse and manage Kafka schema registry subjects, view schema definitions, and track schema evolution - [Security Posture](https://docs.streamkap.com/security-posture.md): Streamkap Security Posture - Quick Links - [Setup SSO](https://docs.streamkap.com/setup-sso.md): Configure single sign-on for your Streamkap organization - [Sign Up](https://docs.streamkap.com/sign-up.md): Create your Streamkap account using email or social authentication - [Snapshots & Backfilling](https://docs.streamkap.com/snapshots.md): Manage snapshot operations to backfill historical data from your source databases. - [Snowflake](https://docs.streamkap.com/snowflake.md): Stream CDC data into Snowflake using Streamkap, with support for upsert and append ingestion modes, schema evolution, and key pair authentication. - [Sources](https://docs.streamkap.com/sources.md) - [Overview](https://docs.streamkap.com/sql-server.md): Streamkap supports syncing SQL Server in real-time using change data capture for: - [SQL Server (Generic)](https://docs.streamkap.com/sql-server-generic.md): SQL Server Change Data Capture Self Hosted or Generic with Streamkap - [Azure SQL Database](https://docs.streamkap.com/sql-server-on-azure-sql-database.md): Azure SQL Database Change Data Capture with Streamkap - [SQL Server on Google Cloud SQL](https://docs.streamkap.com/sql-server-on-google-cloud-sql.md): SQL Server Change Data Capture on Google Cloud SQL with Streamkap - [SQL Server Source FAQ](https://docs.streamkap.com/sql-server-source-faq.md) - [SSH Tunnel](https://docs.streamkap.com/ssh-tunnel.md): Use an SSH tunnel to connect to databases - [Federated Authentication and SSO](https://docs.streamkap.com/sso.md): Configure single sign-on and authentication methods for your organization - [Starburst](https://docs.streamkap.com/starburst.md): Starburst Change Data Capture with Streamkap - [DB2](https://docs.streamkap.com/stream-into-db2.md): Stream data into DB2 - [MySQL](https://docs.streamkap.com/stream-into-mysql.md): Stream data into MySQL - [Oracle](https://docs.streamkap.com/stream-into-oracle.md): Stream data into Oracle - [PostgreSQL](https://docs.streamkap.com/stream-into-postgresql.md): Stream data into PostgreSQL - [SQL Server](https://docs.streamkap.com/stream-into-sqlserver.md): Stream data into SQL Server - [Streamkap Cloud](https://docs.streamkap.com/streamkap-cloud.md): Fully managed CDC platform hosted and operated by Streamkap - [Streamkap Encryption](https://docs.streamkap.com/streamkap-encryption.md): Streamkap Encryption - [Streamkap IP Addresses](https://docs.streamkap.com/streamkap-ip-addresses.md) - [Getting Started](https://docs.streamkap.com/streamkap-provider-for-terraform.md): Manage your Streamkap resources as infrastructure-as-code using Terraform. - [Streamkap Support](https://docs.streamkap.com/streamkap-support.md): Overview on Streamkap Support - [Sub Accounts](https://docs.streamkap.com/sub-accounts.md): Manage multiple accounts with Streamkap - [Supabase](https://docs.streamkap.com/supabase.md): Supabase Change Data Capture Setup with Streamkap - [Tagging](https://docs.streamkap.com/tagging.md): Organize and categorize entities easily in Streamkap - [Users](https://docs.streamkap.com/team-management.md): Manage team members, roles, and access permissions for your organization - [Configuration](https://docs.streamkap.com/terraform-configuration.md): Configure the Streamkap Terraform Provider with credentials and create your first resources. - [Installing Terraform](https://docs.streamkap.com/terraform-installation.md): How to install Terraform on macOS, Windows, and Linux using popular package managers. - [Resource Reference](https://docs.streamkap.com/terraform-resources.md): Quick reference for all Streamkap Terraform Provider resources. - [Topics](https://docs.streamkap.com/topics.md): Browse topics, inspect data, and configure partitions - [Enrich](https://docs.streamkap.com/transform-enrich.md): Lookup values from a cached topic to enrich records. Handles schema evolution and pass-through fields. - [Enrich (Async)](https://docs.streamkap.com/transform-enrich-async.md): Asynchronously call REST APIs to enrich incoming records using dynamic payloads. - [Transform Examples](https://docs.streamkap.com/transform-examples.md): Practical before-and-after examples for pipeline transforms and destination-side transforms. - [Fan Out](https://docs.streamkap.com/transform-fanout.md): Route a single record to multiple output topics based on custom logic. - [Transform / Filter Records](https://docs.streamkap.com/transform-filter-records.md): Apply custom logic to modify or filter records. - [Join](https://docs.streamkap.com/transform-join.md): Join multiple topics. Supports schema evolution and pass-through fields. - [Schema Transforms Supported Types](https://docs.streamkap.com/transform-list-of-data-types.md): Mapping Kafka Data Types and SQL Types. - [Transform Ordering](https://docs.streamkap.com/transform-ordering.md): Understand how transforms are ordered and how execution sequence affects your data pipeline. - [TypeScript Development Kit](https://docs.streamkap.com/transform-typescript-development-kit.md): Development environment for building TypeScript transforms with npm dependencies, testing, and bundling - [Overview](https://docs.streamkap.com/transforms.md) - [Streaming Transforms](https://docs.streamkap.com/transforms-1.md): Create and manage Apache Flink-based data transformations for filtering, enrichment, and aggregation - [Billing & Usage](https://docs.streamkap.com/usage.md): Monitor data usage and understand Streamkap billing metrics - [Audit Logs](https://docs.streamkap.com/view-audit-logs.md): View and search audit logs to track activity in your organization - [Overview](https://docs.streamkap.com/vitess.md) - [Vitess (Generic)](https://docs.streamkap.com/vitess-generic.md) - [VPN](https://docs.streamkap.com/vpn.md) - [Weaviate](https://docs.streamkap.com/weaviate.md): Stream data from Kafka topics into Weaviate vector collections in real-time - [Webhook](https://docs.streamkap.com/webhook.md): Receive Kafka records via HTTP POST/PUT/DELETE requests to a dynamically generated webhook endpoint - [What is CDC?](https://docs.streamkap.com/what-is-cdc.md) - [Kafka (Writing)](https://docs.streamkap.com/write-to-kafka.md): Write directly to Kafka ## OpenAPI Specs - [openapi](https://docs.streamkap.com/openapi/openapi.json) - [stop_blocking_snapshot_sources_stop_blocking_snapshot_post](https://docs.streamkap.com/openapi/stop_blocking_snapshot_sources_stop_blocking_snapshot_post.json) - [snapshot_sources_snapshot_post](https://docs.streamkap.com/openapi/snapshot_sources_snapshot_post.json) - [execute_blocking_snapshot_sources_execute_blocking_snapshot_post](https://docs.streamkap.com/openapi/execute_blocking_snapshot_sources_execute_blocking_snapshot_post.json) - [cancel_snapshot_sources_cancel_snapshot_post](https://docs.streamkap.com/openapi/cancel_snapshot_sources_cancel_snapshot_post.json) ## Optional - [Free Trial](https://app.streamkap.com/?__hstc=157095033.ab3f92cd8f148386d7ab078bc558511c.1755622930359.1755881354597.1755883908073.4&__hssc=157095033.1.1755883908073&__hsfp=1551620669&_gl=1*1842m2l*_gcl_au*ODAwODYxMTU0LjE3NTU2MjIxMjY.*_ga*NjYxMDkzMDMwLjE3NTU2MjIxMjY.*_ga_R90C8XW3LS*czE3NTU4ODEzNTIkbzMkZzEkdDE3NTU4ODQwNDQkajYwJGwwJGgw) - [Blog](https://streamkap.com/blog) - [Subscribe](https://streamkap.substack.com/)