Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.
Zerion Streams delivers interpreted onchain events as a continuous Kafka feed, so you ingest data as it happens instead of polling. It’s built for teams moving high volumes of trade and price data into their own pipelines for indexing, analytics, token discovery, and real-time monitoring.
Streaming is an Enterprise offering, provisioned per customer. It isn’t self-serve: connection details, topics, and schemas are shared during onboarding.
Zerion offers three ways to get data, each suited to a different access pattern:
Best for
Shape
REST
On-demand queries for wallets, portfolios, and history
Request/response, in reaction to a user action
Webhooks
Per-address, user-facing real-time updates
Push notifications for specific watched addresses
Streams
Indexing, discovery, analytics, and monitoring at high throughput
A continuous feed of events across chains into your backend
If you only need updates for a known set of wallets, Webhooks are simpler. Streams are for ingesting the full firehose of activity across chains into your own backend.
Zerion runs a managed Apache Kafka cluster on AWS with protobuf-encoded messages. Consumers connect from their own AWS account over private networking with IAM authentication, so data never traverses the public internet. Our team handles onboarding, access provisioning, and topic and schema details.
Enterprise teams running high-throughput ingestion (indexers, token discovery, analytics, and real-time monitoring), typically already operating on AWS.
Streaming is provisioned per customer as part of an Enterprise plan. To request access, log in to the Dashboard and message us through the support widget, email us at api@zerion.io, or reach out in your shared Slack or Telegram channel if you already have one with us.
Was this page helpful?
{"docsConfig":{"theme":"mint","$schema":"https://mintlify.com/docs.json","name":"Zerion API","description":"Zerion is an Ethereum and Solana wallet and developer platform focused on making blockchain data easy to use.","colors":{"primary":"#2461ED","light":"#2461ED","dark":"#2461ED"},"logo":{"light":"https://mintcdn.com/zerion-f99485ad/7LRY3a3Ldx_ROK8O/logo/light.svg?fit=max\u0026auto=format\u0026n=7LRY3a3Ldx_ROK8O\u0026q=85\u0026s=f451fe390bc92095f03123a8f7d40a7d","dark":"https://mintcdn.com/zerion-f99485ad/7LRY3a3Ldx_ROK8O/logo/dark.svg?fit=max\u0026auto=format\u0026n=7LRY3a3Ldx_ROK8O\u0026q=85\u0026s=4062b6f0d31d9101cb18ec6912f5260c"},"favicon":"https://mintcdn.com/zerion-f99485ad/CtpXHzWVHRggjdYr/images/favicon.png?fit=max\u0026auto=format\u0026n=CtpXHzWVHRggjdYr\u0026q=85\u0026s=ab9d008382caaa72b969c16793e48ba4","api":{"playground":{"display":"interactive"},"examples":{"defaults":"required","languages":["curl","python","javascript","go"],"prefill":true}},"navbar":{"links":[{"href":"https://dashboard.zerion.io","label":"Support"}],"primary":{"type":"button","label":"Dashboard","href":"https://dashboard.zerion.io"}},"footer":{"socials":{"x":"https://x.com/zerion","website":"https://zerion.io","linkedin":"https://www.linkedin.com/company/zeriontech"}},"fonts":{"heading":{"family":"Aeonik Pro","weight":700,"source":"fonts/AeonikPro-VF.woff2","format":"woff2"},"body":{"family":"Aeonik Pro","weight":400,"source":"fonts/AeonikPro-VF.woff2","format":"woff2"}},"integrations":{"ga4":{"measurementId":"G-KKSYM575R1"},"mixpanel":{"projectToken":"18a91a6fe2bdf70794ceb76c03433f19","region":"eu"},"posthog":{"apiKey":"phc_KpX0ph71XObDhlXXMKoAzXMtXYiNMMtDhuA8GvvudZI","apiHost":"https://eu.i.posthog.com"}},"contextual":{"options":["copy","view","chatgpt","claude"],"display":"header"},"styling":{"latex":false},"navigation":{"global":{"anchors":[{"anchor":"Dashboard","icon":"square-terminal","href":"https://dashboard.zerion.io"},{"anchor":"AI \u0026 Agents","icon":"brain","href":"/build-with-ai/overview"}]},"pages":[]}},"deployment":{"deploymentMetadataValue":{"subdomain":"zerion-f99485ad","hasAudioNarration":false,"actualSubdomain":"zerion-f99485ad","customDomains":["developers.zerion.io"],"gitSource":{"type":"github","owner":"zeriontech","repo":"mintlify-docs","deployBranch":"main","contentDirectory":"","isPrivate":true,"mountPath":"","label":""},"chroma":{"liveDeploymentHistoryId":"6ad9ecf625e5b97c63691024","collectionId":"4674d7c4-1f61-4e47-9edd-9674a1672447","schemaVersion":"v3","latestBuiltDeploymentHistoryId":"6ad9ecf625e5b97c63691024"},"feedback":{"thumbs":true},"entitlements":{"AI_CHAT":{"status":"ENABLED"},"WEB_MCP":{"status":"ENABLED"},"NARRATION":{"status":"ENABLED"}},"buildId":"6ad9ecf625e5b97c63691024","clientVersion":"0.0.3990","searchFilterCounts":[{"language":"default","tag":"API Reference","count":40},{"language":"default","tag":"REST API","count":40},{"language":"default","tag":"Home","count":26},{"language":"default","tag":"subscriptions to transactions","count":13},{"language":"default","tag":"Get started","count":9},{"language":"default","tag":"Core concepts","count":9},{"language":"default","tag":"Recipes","count":9},{"language":"default","tag":"Migrating to Zerion API","count":8},{"language":"default","tag":"wallets","count":8},{"language":"default","tag":"Build with AI","count":5}]},"assistantConfig":{"enableAskAiButton":false,"enableStarterQuestions":false,"enableAskAiSearchBar":true},"basePath":"","hasChatPermissions":true,"hasWebMcpPermissions":true,"toggles":[{"name":"kill-isr","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"agent-mintlify-slack","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"editor-v7-file-tree","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"agent-integrations-settings","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"automations-pr-grouping","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"custom-prefix","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"analytics-v7","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"user-flows-analytics","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"no-publish-flow","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"workos-onboarding","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"llms-txt-v2","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"pause-universal-search-reconcile","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"snapshot-serving-live","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"stripTemperatureMiddleware","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"per-site-search-delta","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"support-platform-pylon-zendesk","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"snapshot-serving","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"instant-rollback","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"granular-notifications-server","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"granular-notifications","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"editor-private-page-search","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"automations-fable","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"fixed-ai-action-pricing","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"automation-resolve-merge-conflict","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"scoped-publishing","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"mintql","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"page-level-analytics","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"editor-version-history-v2","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"editor-nav-generations","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"billing-page-v2","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"workspace-projects","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"assistant-v5","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"byok-sep-25","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"fork-pr-previews","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"revalidation-jwt","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"vite-origin","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"editor-agent-model-picker","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"billing-updated-9-15","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"workos-sso-scim","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"hobby-abuse-scan","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"dashboard-inbox","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"workos-signup","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"workos-enabled","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false}],"isAtlas":false,"googleFontsInlined":false},"customCss":[{"filePath":"global.css","content":"@media (max-width:600px){.card-group,.hero-grid,.why-grid{grid-template-columns:1fr!important}.hero-grid img{display:none}}.pill-tabs{display:flex;gap:.5rem;flex-wrap:wrap;margin-bottom:1.5rem}.pill-tab{display:inline-flex;align-items:center;padding:.5rem 1rem;border-radius:.375rem;font-size:.875rem;font-weight:500;cursor:pointer;border:1px solid #e5e7eb;background:#fff;color:#374151;transition:none}.pill-tab:hover{border-color:#e5e7eb;color:#374151}.pill-tab.active{background:#0f172a;color:#fff;border-color:#0f172a}@media (prefers-color-scheme:dark){.pill-tab{background:0 0}.pill-tab,.pill-tab:hover{border-color:#374151;color:#d1d5db}.pill-tab.active{background:#fff;color:#0f172a;border-color:#fff}}.feature-card{display:flex;align-items:center;gap:1rem;padding:1rem 1.25rem;border-radius:.375rem;border:1px solid #e5e7eb;text-decoration:none;color:inherit;transition:none}.feature-card:hover{border-color:#e5e7eb;box-shadow:none}@media (prefers-color-scheme:dark){.feature-card,.feature-card:hover{border-color:#374151}.feature-card:hover{box-shadow:none}}.feature-card-icon{display:flex;align-items:center;justify-content:center;width:2.5rem;height:2.5rem;border-radius:.375rem;background:#f4f4f5;flex-shrink:0}@media (prefers-color-scheme:dark){.feature-card-icon{background:#1e293b}}.hero-cta,.hero-cta:hover{color:#fff!important;text-decoration:none!important;border:0!important;box-shadow:none!important;transform:none!important}.hero-cta{display:inline-flex;align-items:center;gap:.5rem;padding:.625rem 1.5rem;background-color:#2461ed;border-radius:.625rem;font-weight:500;font-size:.9375rem;margin-top:.5rem;position:relative}.hero-cta:hover{background-color:#1b4fc4}.stats-row{display:flex;gap:2rem;margin-top:1.5rem;flex-wrap:wrap}.stat-badge{display:flex;flex-direction:column;gap:.125rem}.stat-badge strong{font-size:1.25rem;color:#3030d4}.stat-badge span{font-size:.8125rem;color:#6b7280}.pricing-slider{-webkit-appearance:none;appearance:none;width:100%;height:.375rem;border-radius:9999px;background:linear-gradient(90deg,#3030d4 0%,#5b5bf0 var(--slider-progress, 0%),#e5e7eb var(--slider-progress, 0%),#e5e7eb 100%);outline:0}.pricing-slider::-webkit-slider-runnable-track{height:.375rem;border-radius:9999px;background:linear-gradient(90deg,#3030d4 0%,#5b5bf0 var(--slider-progress, 0%),#e5e7eb var(--slider-progress, 0%),#e5e7eb 100%)}.pricing-slider::-webkit-slider-thumb{-webkit-appearance:none;appearance:none;width:1rem;height:1rem;margin-top:-.3125rem;border-radius:9999px;background:#fff;border:.1875rem solid #3030d4;box-shadow:0 1px 6px rgba(48,48,212,.25)}.pricing-slider::-moz-range-track{height:.375rem;border:0;border-radius:9999px;background:linear-gradient(90deg,#3030d4 0%,#5b5bf0 var(--slider-progress, 0%),#e5e7eb var(--slider-progress, 0%),#e5e7eb 100%)}.pricing-slider::-moz-range-thumb{width:1rem;height:1rem;border-radius:9999px;background:#fff;border:.1875rem solid #3030d4;box-shadow:0 1px 6px rgba(48,48,212,.25)}@media (prefers-color-scheme:dark){.pricing-slider,.pricing-slider::-moz-range-track,.pricing-slider::-webkit-slider-runnable-track{background:linear-gradient(90deg,#6366f1 0%,#818cf8 var(--slider-progress, 0%),rgba(255,255,255,.14) var(--slider-progress, 0%),rgba(255,255,255,.14) 100%)}.pricing-slider::-moz-range-thumb,.pricing-slider::-webkit-slider-thumb{background:#0f172a;border-color:#818cf8;box-shadow:0 1px 8px rgba(129,140,248,.35)}}.sunset-badge{display:inline-block;margin-top:.625rem;padding:.1875rem .5rem;border-radius:.375rem;font-size:.75rem;font-weight:600;white-space:nowrap;background:rgba(36,97,237,.08);color:#2461ed}@media (prefers-color-scheme:dark){.sunset-badge{background:rgba(91,135,245,.14);color:#5b87f5}}table td,table th{min-width:3rem!important}.chain-support-table td:nth-child(-n+2),.chain-support-table th:nth-child(-n+2){width:1%;white-space:nowrap}#table-of-contents a,aside[aria-label=\"On this page\"i] a,nav[aria-label=\"Table of contents\"i] a{border-left:2px solid transparent;padding-left:.75rem;transition:border-color .15s ease,color .15s ease}#table-of-contents a.active,#table-of-contents a:hover,#table-of-contents a[aria-current],aside[aria-label=\"On this page\"i] a:hover,aside[aria-label=\"On this page\"i] a[aria-current],nav[aria-label=\"Table of contents\"i] a:hover,nav[aria-label=\"Table of contents\"i] a[aria-current]{border-left-color:#2461ed;color:#2461ed}@media (prefers-color-scheme:dark){#table-of-contents a:hover,#table-of-contents a[aria-current],aside[aria-label=\"On this page\"i] a:hover,aside[aria-label=\"On this page\"i] a[aria-current],nav[aria-label=\"Table of contents\"i] a:hover,nav[aria-label=\"Table of contents\"i] a[aria-current]{border-left-color:#5b87f5;color:#5b87f5}}"}],"page":{"pagePath":"streaming","slug":"/streaming","pageMetadata":{"title":"Kafka streaming for onchain events","description":"Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.","href":"/streaming"},"description":{"compiledSource":"\"use strict\";\nconst {jsx: _jsx} = arguments[0];\nconst {useMDXComponents: _provideComponents} = arguments[0];\nfunction _createMdxContent(props) {\n const _components = {\n p: \"p\",\n ..._provideComponents(),\n ...props.components\n };\n return _jsx(_components.p, {\n children: \"Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.\"\n });\n}\nfunction MDXContent(props = {}) {\n const {wrapper: MDXLayout} = {\n ..._provideComponents(),\n ...props.components\n };\n return MDXLayout ? _jsx(MDXLayout, {\n ...props,\n children: _jsx(_createMdxContent, {\n ...props\n })\n }) : _createMdxContent(props);\n}\nreturn {\n default: MDXContent\n};\n","frontmatter":{},"scope":{}},"pageType":"default","mdx":{"mdxSource":{"compiledSource":"\"use strict\";const{Fragment:_Fragment,jsx:_jsx,jsxs:_jsxs}=arguments[0];const{useMDXComponents:_provideComponents}=arguments[0];function _createMdxContent(props){const _components={a:`a`,li:`li`,p:`p`,strong:`strong`,tbody:`tbody`,td:`td`,th:`th`,thead:`thead`,tr:`tr`,ul:`ul`,..._provideComponents(),...props.components},{Heading,Note,Table}=_components;if(!Heading)_missingMdxReference(`Heading`,true);if(!Note)_missingMdxReference(`Note`,true);if(!Table)_missingMdxReference(`Table`,true);return _jsxs(_Fragment,{children:[_jsx(_components.p,{children:`Zerion Streams delivers interpreted onchain events as a continuous Kafka feed, so you ingest data as it happens instead of polling. It’s built for teams moving high volumes of trade and price data into their own pipelines for indexing, analytics, token discovery, and real-time monitoring.`}),`\n`,_jsx(Note,{children:_jsx(_components.p,{children:`Streaming is an Enterprise offering, provisioned per customer. It isn’t self-serve: connection details, topics, and schemas are shared during onboarding.`})}),`\n`,_jsx(Heading,{level:`2`,id:`rest-vs-webhooks-vs-streams`,children:`REST vs webhooks vs streams`}),`\n`,_jsx(_components.p,{children:`Zerion offers three ways to get data, each suited to a different access pattern:`}),`\n`,_jsxs(Table,{children:[_jsx(_components.thead,{children:_jsxs(_components.tr,{children:[_jsx(_components.th,{}),_jsx(_components.th,{children:`Best for`}),_jsx(_components.th,{children:`Shape`})]})}),_jsxs(_components.tbody,{children:[_jsxs(_components.tr,{children:[_jsx(_components.td,{children:_jsx(_components.strong,{children:`REST`})}),_jsx(_components.td,{children:`On-demand queries for wallets, portfolios, and history`}),_jsx(_components.td,{children:`Request/response, in reaction to a user action`})]}),_jsxs(_components.tr,{children:[_jsx(_components.td,{children:_jsx(_components.strong,{children:`Webhooks`})}),_jsx(_components.td,{children:`Per-address, user-facing real-time updates`}),_jsx(_components.td,{children:`Push notifications for specific watched addresses`})]}),_jsxs(_components.tr,{children:[_jsx(_components.td,{children:_jsx(_components.strong,{children:`Streams`})}),_jsx(_components.td,{children:`Indexing, discovery, analytics, and monitoring at high throughput`}),_jsx(_components.td,{children:`A continuous feed of events across chains into your backend`})]})]})]}),`\n`,_jsxs(_components.p,{children:[`If you only need updates for a known set of wallets, `,_jsx(_components.a,{href:`/webhooks`,children:`Webhooks`}),` are simpler. Streams are for ingesting the full firehose of activity across chains into your own backend.`]}),`\n`,_jsx(Heading,{level:`2`,id:`what’s-available`,children:`What’s available`}),`\n`,_jsxs(_components.ul,{children:[`\n`,_jsxs(_components.li,{children:[_jsx(_components.strong,{children:`EVM trade actions`}),` across `,_jsx(_components.a,{href:`/supported-blockchains`,children:`supported EVM chains`})]}),`\n`,_jsx(_components.li,{children:_jsx(_components.strong,{children:`Solana trade actions`})}),`\n`,_jsx(_components.li,{children:_jsx(_components.strong,{children:`Token price events`})}),`\n`]}),`\n`,_jsx(_components.p,{children:`Streams carry the same interpreted, bot-filtered data that powers our transactions and webhooks products, not raw RPC logs.`}),`\n`,_jsx(Heading,{level:`2`,id:`how-it-works`,children:`How it works`}),`\n`,_jsx(_components.p,{children:`Zerion runs a managed Apache Kafka cluster on AWS with protobuf-encoded messages. Consumers connect from their own AWS account over private networking with IAM authentication, so data never traverses the public internet. Our team handles onboarding, access provisioning, and topic and schema details.`}),`\n`,_jsx(Heading,{level:`2`,id:`who-it’s-for`,children:`Who it’s for`}),`\n`,_jsx(_components.p,{children:`Enterprise teams running high-throughput ingestion (indexers, token discovery, analytics, and real-time monitoring), typically already operating on AWS.`}),`\n`,_jsx(Heading,{level:`2`,id:`access`,children:`Access`}),`\n`,_jsxs(_components.p,{children:[`Streaming is provisioned per customer as part of an Enterprise plan. To request access, log in to the `,_jsx(_components.a,{href:`https://dashboard.zerion.io`,children:`Dashboard`}),` and message us through the support widget, email us at `,_jsx(_components.a,{href:`mailto:api@zerion.io`,children:`api@zerion.io`}),`, or reach out in your shared Slack or Telegram channel if you already have one with us.`]})]})}function MDXContent(props={}){const{wrapper:MDXLayout}={..._provideComponents(),...props.components};return MDXLayout?_jsx(MDXLayout,{...props,children:_jsx(_createMdxContent,{...props})}):_createMdxContent(props)}return{default:MDXContent};function _missingMdxReference(id,component){throw new Error(`Expected `+(component?`component`:`object`)+\" `\"+id+\"` to be defined: you likely forgot to import, pass, or provide it.\")}","frontmatter":{},"scope":{"config":{},"pageMetadata":{"title":"Kafka streaming for onchain events","description":"Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.","href":"/streaming"}}},"mdxSourceWithNoJs":null},"mdxExtracts":{"tableOfContents":[{"title":"REST vs webhooks vs streams","slug":"rest-vs-webhooks-vs-streams","depth":2,"children":[]},{"title":"What’s available","slug":"what’s-available","depth":2,"children":[]},{"title":"How it works","slug":"how-it-works","depth":2,"children":[]},{"title":"Who it’s for","slug":"who-it’s-for","depth":2,"children":[]},{"title":"Access","slug":"access","depth":2,"children":[]}],"codeExamples":{}},"jsLinks":[],"subdomain":"zerion-f99485ad","siteName":"Zerion API","title":"Kafka streaming for onchain events - Zerion API","navMaps":{"firstHrefInVersion":{},"firstHrefInLanguage":{}},"lastModified":"2026-09-25T09:17:02.989Z","originalFileLocation":"streaming.mdx"},"headHtml":"\u003cscript data-mint-head>(function(){var d=document.documentElement,p=null;if(!p){try{p=localStorage.getItem(\"isDarkMode\")}catch(e){}if(p==='true')p='dark';else if(p==='false')p='light';if(p!=='light'\u0026\u0026p!=='dark'\u0026\u0026p!=='system')p=\"system\"}var r=p==='system'?(matchMedia(\"(prefers-color-scheme: dark)\").matches?'dark':'light'):p;d.classList.remove(r==='dark'?'light':'dark');d.classList.add(r);d.setAttribute(\"data-theme-preference\",p)})();\u003c/script>\u003cmeta data-mint-head name=\"description\" content=\"Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.\">\u003cmeta data-mint-head name=\"application-name\" content=\"Zerion API\">\u003cmeta data-mint-head name=\"generator\" content=\"Mintlify\">\u003clink data-mint-head rel=\"icon\" type=\"image/png\" sizes=\"192x192\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon/android-chrome-192x192.png\" media=\"(prefers-color-scheme: light)\">\u003clink data-mint-head rel=\"apple-touch-icon\" type=\"image/png\" sizes=\"180x180\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon/apple-touch-icon.png\">\u003clink data-mint-head rel=\"icon\" type=\"image/png\" sizes=\"16x16\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon/favicon-16x16.png\" media=\"(prefers-color-scheme: light)\">\u003clink data-mint-head rel=\"icon\" type=\"image/png\" sizes=\"32x32\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon/favicon-32x32.png\" media=\"(prefers-color-scheme: light)\">\u003clink data-mint-head rel=\"shortcut icon\" type=\"image/x-icon\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon/favicon.ico\" media=\"(prefers-color-scheme: light)\">\u003clink data-mint-head rel=\"icon\" type=\"image/png\" sizes=\"192x192\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon-dark/android-chrome-192x192.png\" media=\"(prefers-color-scheme: dark)\">\u003clink data-mint-head rel=\"icon\" type=\"image/png\" sizes=\"16x16\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon-dark/favicon-16x16.png\" media=\"(prefers-color-scheme: dark)\">\u003clink data-mint-head rel=\"icon\" type=\"image/png\" sizes=\"32x32\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon-dark/favicon-32x32.png\" media=\"(prefers-color-scheme: dark)\">\u003clink data-mint-head rel=\"shortcut icon\" type=\"image/x-icon\" href=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon-dark/favicon.ico\" media=\"(prefers-color-scheme: dark)\">\u003cmeta data-mint-head property=\"og:title\" content=\"Kafka streaming for onchain events - Zerion API\">\u003cmeta data-mint-head property=\"og:description\" content=\"Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.\">\u003cmeta data-mint-head property=\"og:site_name\" content=\"Zerion API\">\u003cmeta data-mint-head property=\"og:url\" content=\"https://developers.zerion.io/streaming\">\u003cmeta data-mint-head property=\"og:type\" content=\"website\">\u003cmeta data-mint-head property=\"og:image\" content=\"https://zerion-f99485ad.mintlify.app/_mintlify/api/og/v2?division=Core+concepts\u0026amp;title=Kafka+streaming+for+onchain+events\u0026amp;description=Subscribe+to+real-time+onchain+event+streams+from+Zerion+API+over+Kafka+for+high-throughput+data+pipelines%2C+indexers%2C+and+internal+analytics+workloads.\u0026amp;theme=84bd58406d825a4dc94e9d1b\u0026amp;signature=0045f73aee347907f5bd86fb5abbf4bc8d98e0403e738bb872d0926509cadeed\">\u003cmeta data-mint-head property=\"og:image:width\" content=\"1200\">\u003cmeta data-mint-head property=\"og:image:height\" content=\"630\">\u003cmeta data-mint-head name=\"twitter:card\" content=\"summary_large_image\">\u003cmeta data-mint-head name=\"twitter:title\" content=\"Kafka streaming for onchain events - Zerion API\">\u003cmeta data-mint-head name=\"twitter:description\" content=\"Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.\">\u003cmeta data-mint-head name=\"twitter:image\" content=\"https://zerion-f99485ad.mintlify.app/_mintlify/api/og/v2?division=Core+concepts\u0026amp;title=Kafka+streaming+for+onchain+events\u0026amp;description=Subscribe+to+real-time+onchain+event+streams+from+Zerion+API+over+Kafka+for+high-throughput+data+pipelines%2C+indexers%2C+and+internal+analytics+workloads.\u0026amp;theme=84bd58406d825a4dc94e9d1b\u0026amp;signature=0045f73aee347907f5bd86fb5abbf4bc8d98e0403e738bb872d0926509cadeed\">\u003cmeta data-mint-head name=\"twitter:image:width\" content=\"1200\">\u003cmeta data-mint-head name=\"twitter:image:height\" content=\"630\">\u003cmeta data-mint-head name=\"msapplication-config\" content=\"/mintlify-assets/_mintlify/favicons/zerion-f99485ad/VzHsQ_h3ouhCUDnV/_generated/favicon/browserconfig.xml\">\u003cmeta data-mint-head name=\"apple-mobile-web-app-title\" content=\"Zerion API\">\u003cmeta data-mint-head name=\"msapplication-TileColor\" content=\"#2461ED\">\u003clink data-mint-head rel=\"canonical\" href=\"https://developers.zerion.io/streaming\">\u003clink data-mint-head rel=\"alternate\" type=\"application/xml\" href=\"/sitemap.xml\">\u003clink data-mint-head rel=\"alternate\" type=\"text/markdown\" href=\"/streaming.md\">\u003cscript data-mint-head type=\"application/ld+json\">{\"@context\":\"https://schema.org\",\"@graph\":[{\"@type\":\"Organization\",\"@id\":\"https://developers.zerion.io/#organization\",\"name\":\"Zerion API\",\"url\":\"https://developers.zerion.io\",\"logo\":{\"@type\":\"ImageObject\",\"url\":\"https://mintcdn.com/zerion-f99485ad/7LRY3a3Ldx_ROK8O/logo/light.svg?fit=max\u0026auto=format\u0026n=7LRY3a3Ldx_ROK8O\u0026q=85\u0026s=f451fe390bc92095f03123a8f7d40a7d\"}},{\"@type\":\"WebSite\",\"@id\":\"https://developers.zerion.io#website\",\"name\":\"Zerion API\",\"url\":\"https://developers.zerion.io\",\"publisher\":{\"@id\":\"https://developers.zerion.io/#organization\"}},{\"@type\":\"WebPage\",\"@id\":\"https://developers.zerion.io/streaming#webpage\",\"url\":\"https://developers.zerion.io/streaming\",\"name\":\"Kafka streaming for onchain events\",\"description\":\"Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.\",\"dateModified\":\"2026-09-25T09:17:02.989Z\",\"isPartOf\":{\"@id\":\"https://developers.zerion.io#website\"},\"breadcrumb\":{\"@id\":\"https://developers.zerion.io/streaming#breadcrumb\"}},{\"@type\":\"BreadcrumbList\",\"@id\":\"https://developers.zerion.io/streaming#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Core concepts\",\"item\":\"https://developers.zerion.io/supported-blockchains\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Kafka streaming for onchain events\",\"item\":\"https://developers.zerion.io/streaming\"}]},{\"@type\":[\"Article\",\"TechArticle\"],\"@id\":\"https://developers.zerion.io/streaming#article\",\"headline\":\"Kafka streaming for onchain events\",\"name\":\"Kafka streaming for onchain events\",\"description\":\"Subscribe to real-time onchain event streams from Zerion API over Kafka for high-throughput data pipelines, indexers, and internal analytics workloads.\",\"url\":\"https://developers.zerion.io/streaming\",\"mainEntityOfPage\":{\"@id\":\"https://developers.zerion.io/streaming#webpage\"},\"dateModified\":\"2026-09-25T09:17:02.989Z\",\"publisher\":{\"@id\":\"https://developers.zerion.io/#organization\"},\"isPartOf\":{\"@id\":\"https://developers.zerion.io#website\"}}]}\u003c/script>\u003cscript data-mint-head type=\"application/ld+json\">{\"@context\":\"https://schema.org\",\"@type\":\"WebSite\",\"name\":\"Zerion API\",\"creator\":{\"@type\":\"Organization\",\"name\":\"Mintlify\",\"url\":\"https://mintlify.com\"}}\u003c/script>","siteName":"Zerion API","nav":{"global":{"anchors":[{"anchor":"Dashboard","icon":"square-terminal","href":"https://dashboard.zerion.io"},{"anchor":"AI \u0026 Agents","icon":"brain","href":"/build-with-ai/overview"}]},"tabs":[{"tab":"Home","groups":[{"group":"Get started","pages":[{"title":"Introduction to Zerion API","sidebarTitle":"Introduction","href":"/introduction"},{"title":"Quickstart","href":"/quickstart"},{"title":"Authentication","href":"/authentication"},{"group":"Build with AI","pages":[{"title":"Build AI agents with onchain data","href":"/build-with-ai/overview"},{"title":"Zerion CLI and agent skills for AI coding tools","href":"/build-with-ai/zerion-cli"},{"title":"x402 payments: pay-per-request Zerion API access","href":"/build-with-ai/x402"},{"title":"MPP payments: pay-per-request Zerion API access","href":"/build-with-ai/mpp"},{"title":"Model Context Protocol (MCP) server","href":"/build-with-ai/mcp"}]},{"title":"Migrate to Zerion API","sidebarTitle":"Migrate to Zerion","href":"/migrate-to-zerion"}]},{"group":"Core concepts","pages":[{"title":"Supported blockchains and chain IDs for Zerion API","sidebarTitle":"Supported blockchains","mode":"wide","href":"/supported-blockchains"},{"title":"Endpoints and response schema","href":"/endpoints-and-schema"},{"title":"Pagination, filtering, sorting, and currency","href":"/pagination-and-filtering"},{"title":"Error handling and status codes","href":"/error-handling"},{"title":"Rate limits and throttling","href":"/rate-limits"},{"title":"Webhooks for real-time wallet transaction notifications","description":"Subscribe to wallet activity and receive real-time webhook callbacks the moment a watched wallet sends or receives a transaction on EVM chains or Solana.","href":"/webhooks"},{"title":"Kafka streaming for onchain events","href":"/streaming"},{"title":"Spam token filtering","description":"How Zerion detects and filters spam and scam tokens across wallet positions, transactions, and NFTs, and how to opt in or out of trust filtering per request.","href":"/spam-filtering"},{"title":"Real-world asset (RWA) classification","sidebarTitle":"RWA classification","href":"/rwa-classification"}]},{"group":"Migrating to Zerion API","pages":[{"title":"Migrate from Zapper to Zerion API","sidebarTitle":"From Zapper","href":"/migrate-from-zapper"},{"title":"Migrate from Dune SIM to Zerion API","sidebarTitle":"From Dune SIM","href":"/migrate-from-sim"},{"title":"Migrate from Mobula to Zerion API","sidebarTitle":"From Mobula","href":"/migrate-from-mobula"},{"title":"Migrate from OneBalance to Zerion API","sidebarTitle":"From OneBalance","href":"/migrate-from-onebalance"},{"title":"Migrate from DeBank Cloud to Zerion API","sidebarTitle":"From DeBank","href":"/migrate-from-debank"},{"title":"Migrate from Allium to Zerion API","sidebarTitle":"From Allium","href":"/migrate-from-allium"},{"title":"Migrate from GoldRush (Covalent) to Zerion API","sidebarTitle":"From GoldRush","href":"/migrate-from-goldrush"},{"title":"Migrate from Moralis to Zerion API","sidebarTitle":"From Moralis","href":"/migrate-from-moralis"}]}]},{"tab":"API Reference","pages":[{"title":"API Reference","href":"/api-reference/wallets/get-wallet-balance-chart"}]},{"tab":"Recipes","pages":[{"title":"Recipes","href":"/recipes"}]},{"tab":"Case studies","href":"https://zerion.io/blog/tag/zerion-api/"},{"tab":"Changelogs","pages":[{"title":"Changelogs","href":"/changelog"}]}]},"title":"Kafka streaming for onchain events - Zerion API","buildId":"dpl_2oYXwqkEXirXBPk8wV1FtM5USFWi","deploymentId":"dpl_2oYXwqkEXirXBPk8wV1FtM5USFWi","dynamics":[],"chunks":[]}