In this tutorial, you will build Java client applications which produce and consume messages from an Apache Kafka® cluster.As you learn how to run your first Kafka application, we recommend using StreamNative Cloud so you don’t have to run your own Kafka cluster and can focus on client development.If you do not already have an account, you can follow the steps below to sign up for StreamNative Cloud. New signups receive $200 to spend within StreamNative Cloud. No credit card is required for the first 30 days or until your credits run out.
If you have an email account configured for using Single Sign-On (SSO) with StreamNative Cloud, use that email address and password when signing up.
To sign up, navigate to the StreamNative Cloud Console login page. Follow the prompts to create an account.After you click Finish, you might have to wait briefly for your first organization to be created.
Was this page helpful?
⌘I
{"docsConfig":{"theme":"luma","$schema":"https://mintlify.com/docs.json","name":"StreamNative Documentation","colors":{"primary":"#177bed","light":"#B9D7FA","dark":"#0e4a8e"},"logo":{"light":"https://mintcdn.com/streamnative/SC0zqekRwf8nvf5H/logo/light.svg?fit=max\u0026auto=format\u0026n=SC0zqekRwf8nvf5H\u0026q=85\u0026s=a0e61dd3a50e9c0288bf4e3ea0a398be","dark":"https://mintcdn.com/streamnative/SC0zqekRwf8nvf5H/logo/dark.svg?fit=max\u0026auto=format\u0026n=SC0zqekRwf8nvf5H\u0026q=85\u0026s=7f1091351e4896879ce3b26d2363e4f4"},"favicon":"https://mintcdn.com/streamnative/_E3AfN6vzMatrPox/favicon.svg?fit=max\u0026auto=format\u0026n=_E3AfN6vzMatrPox\u0026q=85\u0026s=dac7639f549cf27f910111f7ac2d02dd","background":{"color":{"dark":"#0A0B0D"}},"navbar":{"links":[{"href":"/support/get-support","label":"Support"}],"primary":{"type":"button","label":"Console","href":"https://console.streamnative.cloud"}},"footer":{"socials":{"x":"https://x.com/streamnative.io","github":"https://github.com/streamnative","linkedin":"https://linkedin.com/company/streamnative"}},"seo":{"metatags":{"canonical":"https://docs.streamnative.io","og:site_name":"StreamNative Documentation","og:type":"website","og:image":"https://docs.streamnative.io/logo/light.svg","twitter:card":"summary_large_image","twitter:site":"@streamnativeio"},"indexing":"all"},"fonts":{"heading":{"family":"Funnel Display","weight":500},"body":{"family":"Funnel Sans","weight":400}},"contextual":{"options":["copy","view","chatgpt","claude"],"display":"header"},"styling":{"latex":true},"navigation":{"pages":[]}},"deployment":{"deploymentMetadataValue":{"subdomain":"streamnative","hasAudioNarration":false,"actualSubdomain":"streamnative","customDomains":["docs.streamnative.io"],"gitSource":{"type":"github","owner":"streamnative","repo":"sn-docs","deployBranch":"main","contentDirectory":"","isPrivate":true,"mountPath":"","label":""},"chroma":{"liveDeploymentHistoryId":"6ae161b0ead346a726da45ca","collectionId":"52991245-13e5-4b84-b56a-422ed59bb2fd","schemaVersion":"v3","latestBuiltDeploymentHistoryId":"6ae161b0ead346a726da45ca"},"feedback":{"thumbs":true},"entitlements":{"AI_CHAT":{"status":"ENABLED"},"REMOVE_BRANDING":{"status":"DISABLED"},"CONTEXTUAL_FEEDBACK":{"status":"DISABLED"},"CODE_SNIPPET_FEEDBACK":{"status":"DISABLED"},"WEB_MCP":{"status":"ENABLED"},"NARRATION":{"status":"ENABLED"}},"buildId":"6ae161b0ead346a726da45ca","clientVersion":"0.0.3990","searchFilterCounts":[{"language":"default","tag":"StreamNative Cloud","count":811},{"language":"default","tag":"Pulsar","count":662},{"language":"default","tag":"StreamNative Private Cloud","count":300},{"language":"default","tag":"Pulsar Changelogs","count":270},{"language":"default","tag":"Kafka","count":163},{"language":"default","tag":"References","count":150},{"language":"default","tag":"Resources","count":146},{"language":"default","tag":"Streamnative Pulsar Changelogs","count":117},{"language":"default","tag":"Kafka Clients","count":97},{"language":"default","tag":"Guides","count":83}]},"assistantConfig":{"deflection":{"enabled":true,"email":"support@streamnative.io","showHelpButton":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":true},"customCss":[{"filePath":"style.css","content":"/* latin-ext */\n@font-face {\n font-family: 'DM Mono';\n font-style: normal;\n font-weight: 400;\n font-display: swap;\n src: url(/_mintlify/assets/fonts/google/s/dmmono/v16/aFTU7PB1QTsUX8KYthSQBLyM.woff2) format('woff2');\n unicode-range: U+0100-02BA, U+02BD-02C5, U+02C7-02CC, U+02CE-02D7, U+02DD-02FF, U+0304, U+0308, U+0329, U+1D00-1DBF, U+1E00-1E9F, U+1EF2-1EFF, U+2020, U+20A0-20AB, U+20AD-20C4, U+2113, U+2C60-2C7F, U+A720-A7FF;\n}\n/* latin */\n@font-face {\n font-family: 'DM Mono';\n font-style: normal;\n font-weight: 400;\n font-display: swap;\n src: url(/_mintlify/assets/fonts/google/s/dmmono/v16/aFTU7PB1QTsUX8KYthqQBA.woff2) format('woff2');\n unicode-range: U+0000-00FF, U+0131, U+0152-0153, U+02BB-02BC, U+02C6, U+02DA, U+02DC, U+0304, U+0308, U+0329, U+2000-206F, U+20AC, U+2122, U+2191, U+2193, U+2212, U+2215, U+FEFF, U+FFFD;\n}\n/* latin-ext */\n@font-face {\n font-family: 'Funnel Sans';\n font-style: normal;\n font-weight: 500;\n font-display: swap;\n src: url(/_mintlify/assets/fonts/google/s/funnelsans/v3/OpNfno8Dg9bX6Bsp3Wq69RB-VukSVv3aISFAp3m0d2VMrDw.woff2) format('woff2');\n unicode-range: U+0100-02BA, U+02BD-02C5, U+02C7-02CC, U+02CE-02D7, U+02DD-02FF, U+0304, U+0308, U+0329, U+1D00-1DBF, U+1E00-1E9F, U+1EF2-1EFF, U+2020, U+20A0-20AB, U+20AD-20C4, U+2113, U+2C60-2C7F, U+A720-A7FF;\n}\n/* latin */\n@font-face {\n font-family: 'Funnel Sans';\n font-style: normal;\n font-weight: 500;\n font-display: swap;\n src: url(/_mintlify/assets/fonts/google/s/funnelsans/v3/OpNfno8Dg9bX6Bsp3Wq69RB-VukSVv3aISFAp3m0eWVM.woff2) format('woff2');\n unicode-range: U+0000-00FF, U+0131, U+0152-0153, U+02BB-02BC, U+02C6, U+02DA, U+02DC, U+0304, U+0308, U+0329, U+2000-206F, U+20AC, U+2122, U+2191, U+2193, U+2212, U+2215, U+FEFF, U+FFFD;\n}\ncode,kbd,pre,samp{font-family:'DM Mono',ui-monospace,SFMono-Regular,Menlo,Monaco,Consolas,'Liberation Mono','Courier New',monospace;font-size:.875rem;line-height:1.6;letter-spacing:0}h1,h2,h3,h4{font-weight:500}h1{font-family:'Funnel Display',sans-serif;font-size:2rem;letter-spacing:-.02em}h2,h3,h4{font-family:'Funnel Sans',sans-serif}h1,h2{line-height:1.2}h2{font-size:1.5rem;letter-spacing:-.01em}h3,h4{letter-spacing:0}h2,h3{margin-top:2rem;margin-bottom:1rem}h3{font-size:1.25rem;line-height:1.3}h4{font-size:1.125rem;line-height:1.4}body{color:#485565}.dark body,.dark main{color:#9aa4b2}.dark h1,.dark h2,.dark h3,.dark h4{color:#fff}div:has(>.nav-dropdown-products-selector-trigger)>:nth-child(2){order:1}"}],"page":{"pagePath":"clients/kafka-clients/java/tutorial/kafka-java-introduction","slug":"/clients/kafka-clients/java/tutorial/kafka-java-introduction","pageMetadata":{"title":"Introduction","id":"kafka-java-introduction","category":"get-started","redirects":null,"tags":["get started","Kafka","Java"],"sidebarTitle":"Introduction","description":null,"href":"/clients/kafka-clients/java/tutorial/kafka-java-introduction"},"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`,p:`p`,strong:`strong`,..._provideComponents(),...props.components},{Heading,Note}=_components;if(!Heading)_missingMdxReference(`Heading`,true);if(!Note)_missingMdxReference(`Note`,true);return _jsxs(_Fragment,{children:[_jsx(_components.p,{children:`In this tutorial, you will build Java client applications which produce and consume messages from an Apache Kafka® cluster.`}),`\n`,_jsxs(_components.p,{children:[`As you learn how to run your first Kafka application, we recommend using `,_jsx(_components.a,{href:`https://streamnative.io/deployment`,children:`StreamNative Cloud`}),` so you don’t have to run your own Kafka cluster and can focus on client development.`]}),`\n`,_jsx(_components.p,{children:`If you do not already have an account, you can follow the steps below to sign up for StreamNative Cloud. New signups receive $200 to spend within StreamNative Cloud. No credit card is required for the first 30 days or until your credits run out.`}),`\n`,_jsx(Heading,{level:`2`,id:`sign-up-for-streamnative-cloud`,children:`Sign up for StreamNative Cloud`}),`\n`,_jsx(Note,{title:`Note`,children:_jsx(_components.p,{children:`If you have an email account configured for using Single Sign-On (SSO) with StreamNative Cloud, use that email address and password when signing up.`})}),`\n`,_jsxs(_components.p,{children:[`To sign up, navigate to the `,_jsx(_components.a,{href:`https://console.streamnative.cloud/?defaultMethod=signup`,children:`StreamNative Cloud Console login page`}),`. Follow the prompts to create an account.`]}),`\n`,_jsxs(_components.p,{children:[`After you click `,_jsx(_components.strong,{children:`Finish`}),`, you might have to wait briefly for your first organization to be created.`]})]})}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":"Introduction","id":"kafka-java-introduction","category":"get-started","redirects":null,"tags":["get started","Kafka","Java"],"sidebarTitle":"Introduction","description":null,"href":"/clients/kafka-clients/java/tutorial/kafka-java-introduction"}}},"mdxSourceWithNoJs":null},"mdxExtracts":{"tableOfContents":[{"title":"Sign up for StreamNative Cloud","slug":"sign-up-for-streamnative-cloud","depth":2,"children":[]}],"codeExamples":{}},"jsLinks":["/_mintlify/custom/streamnative/9e165e8cbf8e8808/scripts/fix-hub-meta.js","/_mintlify/custom/streamnative/c2d281dc3d246a54/scripts/fix-hub-note.js","/_mintlify/custom/streamnative/5855b8c91ee0723b/scripts/fix-hub-tab.js","/_mintlify/custom/streamnative/2ae2ad30d0ad3c68/scripts/import/importDocs.js","/_mintlify/custom/streamnative/a68a187867c1e64a/scripts/hub/fix-hub-meta.js","/_mintlify/custom/streamnative/0f92aab004f53e53/scripts/hub/fix-hub-note.js","/_mintlify/custom/streamnative/ad536b8b4d2d9ba0/scripts/hub/fix-hub-tab.js","/_mintlify/custom/streamnative/d16acfa2fc71d4c8/connect/sync.js","/_mintlify/custom/streamnative/01a1b96abbfd1fe3/scripts/sync-pulsar-release-channels.js","/_mintlify/custom/streamnative/e81c5fd9954b02fe/scripts/validate-docs-nav.js"],"subdomain":"streamnative","siteName":"StreamNative Documentation","title":"Introduction - StreamNative Documentation","navMaps":{"firstHrefInVersion":{},"firstHrefInLanguage":{}},"lastModified":"2026-10-28T02:45:45.485Z","originalFileLocation":"clients/kafka-clients/java/tutorial/kafka-java-introduction.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=\"application-name\" content=\"StreamNative Documentation\">\u003cmeta data-mint-head name=\"generator\" content=\"Mintlify\">\u003clink data-mint-head rel=\"icon\" type=\"image/png\" sizes=\"192x192\" href=\"/mintlify-assets/_mintlify/favicons/streamnative/jTGt9etb1f_opncu/_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/streamnative/jTGt9etb1f_opncu/_generated/favicon/apple-touch-icon.png\">\u003clink data-mint-head rel=\"icon\" type=\"image/png\" sizes=\"16x16\" href=\"/mintlify-assets/_mintlify/favicons/streamnative/jTGt9etb1f_opncu/_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/streamnative/jTGt9etb1f_opncu/_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/streamnative/jTGt9etb1f_opncu/_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/streamnative/jTGt9etb1f_opncu/_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/streamnative/jTGt9etb1f_opncu/_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/streamnative/jTGt9etb1f_opncu/_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/streamnative/jTGt9etb1f_opncu/_generated/favicon-dark/favicon.ico\" media=\"(prefers-color-scheme: dark)\">\u003cmeta data-mint-head property=\"og:title\" content=\"Introduction - StreamNative Documentation\">\u003cmeta data-mint-head property=\"og:site_name\" content=\"StreamNative Documentation\">\u003cmeta data-mint-head property=\"og:url\" content=\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction\">\u003cmeta data-mint-head property=\"og:type\" content=\"website\">\u003cmeta data-mint-head property=\"og:image\" content=\"https://docs.streamnative.io/logo/light.svg\">\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=\"Introduction - StreamNative Documentation\">\u003cmeta data-mint-head name=\"twitter:image\" content=\"https://docs.streamnative.io/logo/light.svg\">\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/streamnative/jTGt9etb1f_opncu/_generated/favicon/browserconfig.xml\">\u003cmeta data-mint-head name=\"apple-mobile-web-app-title\" content=\"StreamNative Documentation\">\u003cmeta data-mint-head name=\"msapplication-TileColor\" content=\"#177bed\">\u003clink data-mint-head rel=\"canonical\" href=\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction\">\u003clink data-mint-head rel=\"alternate\" type=\"application/xml\" href=\"/sitemap.xml\">\u003clink data-mint-head rel=\"alternate\" type=\"text/markdown\" href=\"/clients/kafka-clients/java/tutorial/kafka-java-introduction.md\">\u003cscript data-mint-head type=\"application/ld+json\">{\"@context\":\"https://schema.org\",\"@graph\":[{\"@type\":\"Organization\",\"@id\":\"https://docs.streamnative.io/#organization\",\"name\":\"StreamNative Documentation\",\"url\":\"https://docs.streamnative.io\",\"logo\":{\"@type\":\"ImageObject\",\"url\":\"https://mintcdn.com/streamnative/SC0zqekRwf8nvf5H/logo/light.svg?fit=max\u0026auto=format\u0026n=SC0zqekRwf8nvf5H\u0026q=85\u0026s=a0e61dd3a50e9c0288bf4e3ea0a398be\"}},{\"@type\":\"WebSite\",\"@id\":\"https://docs.streamnative.io#website\",\"name\":\"StreamNative Documentation\",\"url\":\"https://docs.streamnative.io\",\"publisher\":{\"@id\":\"https://docs.streamnative.io/#organization\"}},{\"@type\":\"WebPage\",\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction#webpage\",\"url\":\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction\",\"name\":\"Introduction\",\"dateModified\":\"2026-10-28T02:45:45.485Z\",\"isPartOf\":{\"@id\":\"https://docs.streamnative.io#website\"},\"breadcrumb\":{\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction#breadcrumb\"}},{\"@type\":\"BreadcrumbList\",\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Kafka Clients\",\"item\":\"https://docs.streamnative.io/cloud/build/kafka-clients/kafka-on-cloud\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Guides\",\"item\":\"https://docs.streamnative.io/clients/kafka-clients/kafka-clients-overview\"},{\"@type\":\"ListItem\",\"position\":3,\"name\":\"Java\",\"item\":\"https://docs.streamnative.io/clients/kafka-clients/java/kafka-java-client-guide\"},{\"@type\":\"ListItem\",\"position\":4,\"name\":\"Introduction\",\"item\":\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction\"}]},{\"@type\":[\"Article\",\"TechArticle\"],\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction#article\",\"headline\":\"Introduction\",\"name\":\"Introduction\",\"url\":\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction\",\"mainEntityOfPage\":{\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/java/tutorial/kafka-java-introduction#webpage\"},\"image\":\"https://docs.streamnative.io/logo/light.svg\",\"dateModified\":\"2026-10-28T02:45:45.485Z\",\"publisher\":{\"@id\":\"https://docs.streamnative.io/#organization\"},\"isPartOf\":{\"@id\":\"https://docs.streamnative.io#website\"}}]}\u003c/script>\u003cscript data-mint-head type=\"application/ld+json\">{\"@context\":\"https://schema.org\",\"@type\":\"WebSite\",\"name\":\"StreamNative Documentation\",\"creator\":{\"@type\":\"Organization\",\"name\":\"Mintlify\",\"url\":\"https://mintlify.com\"}}\u003c/script>","siteName":"StreamNative Documentation","nav":{"global":null,"products":[{"product":"StreamNative Cloud","icon":"cloud","description":"Serverless, Dedicated, and BYOC","tabs":[{"tab":"Welcome","pages":[{"title":"Welcome","href":"/home"}]},{"tab":"Concepts","pages":[{"title":"Concepts","href":"/cloud/overview/cloud-overview"}]},{"tab":"Pulsar","pages":[{"title":"Pulsar","href":"/cloud/get-started/quickstart-console"}]},{"tab":"Kafka","groups":[{"group":"Introduction","pages":[{"title":"StreamNative Kafka Service","sidebarTitle":"Overview","href":"/kafka/overview"},{"title":"Kafka Cluster vs. KSN on Pulsar Clusters","sidebarTitle":"Kafka Cluster vs. KSN","href":"/kafka/kafka-cluster-vs-ksn"}]},{"group":"Get Started","pages":[{"title":"QuickStart - Kafka Client","sidebarTitle":"Kafka APIs","href":"/cloud/get-started/quickstart-kafka"},{"title":"Get Started with Kafka Service","sidebarTitle":"Get Started","href":"/kafka/kafka-getting-started"}]},{"group":"Kafka Clusters","pages":[{"title":"Manage Kafka Clusters","sidebarTitle":"Kafka Cluster Guide","href":"/kafka/kafka-cluster-guide"}]},{"group":"Process","pages":[{"title":"Kafka Streams \u0026 KSQL","sidebarTitle":"Overview","href":"/cloud/process/kafka-streams-and-ksql/kafka-streams-and-ksql"},{"title":"Connect to your cluster using the Kafka Stream","sidebarTitle":"Kafka Streams","href":"/cloud/process/kafka-streams-and-ksql/cloud-connect-kafka-stream"},{"title":"Connect to your cluster using KSQL","sidebarTitle":"KSQL","href":"/cloud/process/kafka-streams-and-ksql/cloud-connect-ksql"}]},{"group":"Lakehouse","pages":[{"title":"Overview - Lakehouse Tables","sidebarTitle":"Overview","href":"/cloud/lakehouse/lakehouse-tables-overview"},{"title":"Lakehouse Table Overview","sidebarTitle":"Lakehouse Table Overview","href":"/cloud/lakehouse/lakehouse-table-overview"},{"title":"Enable Lakehouse Table","sidebarTitle":"Enable Lakehouse Table","href":"/cloud/lakehouse/enable-lakehouse-integration"},{"group":"Lakehouse Features","pages":[{"title":"Lakehouse Features Overview","sidebarTitle":"Overview","href":"/cloud/lakehouse/lakehouse-features"},{"title":"Schema Evolution","sidebarTitle":"Schema Evolution","href":"/cloud/lakehouse/features/schema-evolution"},{"title":"Variant Type","sidebarTitle":"Variant Type","href":"/cloud/lakehouse/features/variant-type"},{"title":"Partition Key","sidebarTitle":"Partition Key","href":"/cloud/lakehouse/features/iceberg-partition-key"},{"title":"Upsert","sidebarTitle":"Upsert","href":"/cloud/lakehouse/features/iceberg-upsert"},{"title":"Persist Key","sidebarTitle":"Persist Key","href":"/cloud/lakehouse/features/persist-key"},{"title":"Persist Extra Metadata","sidebarTitle":"Persist Extra Metadata","href":"/cloud/lakehouse/features/persist-extra-metadata"},{"title":"Data Lineage","sidebarTitle":"Data Lineage","href":"/cloud/lakehouse/features/lineage"}]},{"group":"Internal Tables","pages":[{"title":"Overview - Internal Tables","sidebarTitle":"Overview","href":"/cloud/lakehouse/internal-tables/internal-tables-overview"}]},{"group":"External Tables","pages":[{"title":"Overview - External Tables","sidebarTitle":"Overview","href":"/cloud/lakehouse/external-tables/external-tables-overview"}]},{"group":"Catalogs","pages":[{"title":"Overview of StreamNative Catalogs","sidebarTitle":"Overview","href":"/cloud/lakehouse/catalogs/catalog-overview"},{"group":"Prepare Catalogs","pages":[{"title":"Prepare Lakehouse Catalogs","sidebarTitle":"Prepare Lakehouse Catalogs","href":"/cloud/lakehouse/prepare-lakehouse-catalogs"},{"title":"BigLake for Iceberg","sidebarTitle":"BigLake for Iceberg","href":"/cloud/lakehouse/prepare-catalogs/biglake/iceberg"},{"title":"Horizon Catalog for Iceberg on AWS","sidebarTitle":"Horizon Catalog for Iceberg on AWS","href":"/cloud/lakehouse/prepare-catalogs/horizon-catalog/iceberg/aws"},{"group":"Open Catalog (Iceberg)","pages":[{"title":"Open Catalog for Iceberg on AWS","sidebarTitle":"Open Catalog for Iceberg on AWS","href":"/cloud/lakehouse/prepare-catalogs/open-catalog/iceberg/aws"},{"title":"Open Catalog for Iceberg on Azure","sidebarTitle":"Open Catalog for Iceberg on Azure","href":"/cloud/lakehouse/prepare-catalogs/open-catalog/iceberg/azure"},{"title":"Open Catalog for Iceberg on GCP","sidebarTitle":"Open Catalog for Iceberg on GCP","href":"/cloud/lakehouse/prepare-catalogs/open-catalog/iceberg/gcp"}]},{"title":"S3Table for Iceberg","sidebarTitle":"S3Table for Iceberg","href":"/cloud/lakehouse/prepare-catalogs/s3table/iceberg"},{"group":"Unity Catalog (Iceberg)","pages":[{"title":"Unity Catalog Managed Iceberg Table on AWS","sidebarTitle":"Unity Catalog Managed Iceberg Table on AWS","href":"/cloud/lakehouse/prepare-catalogs/unity-catalog/iceberg/aws"},{"title":"Unity Catalog Managed Iceberg Table on Azure","sidebarTitle":"Unity Catalog Managed Iceberg Table on Azure","href":"/cloud/lakehouse/prepare-catalogs/unity-catalog/iceberg/azure"},{"title":"Unity Catalog Managed Iceberg Table on GCP","sidebarTitle":"Unity Catalog Managed Iceberg Table on GCP","href":"/cloud/lakehouse/prepare-catalogs/unity-catalog/iceberg/gcp"}]},{"group":"Unity Catalog (Delta Lake)","pages":[{"title":"Unity Catalog for Delta Lake on AWS","sidebarTitle":"Unity Catalog for Delta Lake on AWS","href":"/cloud/lakehouse/prepare-catalogs/unity-catalog/delta-lake/aws"},{"title":"Unity Catalog for Delta Lake on Azure","sidebarTitle":"Unity Catalog for Delta Lake on Azure","href":"/cloud/lakehouse/prepare-catalogs/unity-catalog/delta-lake/azure"},{"title":"Unity Catalog for Delta Lake on GCP","sidebarTitle":"Unity Catalog for Delta Lake on GCP","href":"/cloud/lakehouse/prepare-catalogs/unity-catalog/delta-lake/gcp"}]}]},{"title":"Register Catalog","sidebarTitle":"Register catalog","href":"/cloud/lakehouse/catalogs/register-catalog"},{"title":"Manage StreamNative Catalogs","sidebarTitle":"Manage catalogs","href":"/cloud/lakehouse/catalogs/manage-catalogs"},{"group":"Private Networking","pages":[{"title":"Private Networking for Catalog Integration","sidebarTitle":"Overview","href":"/cloud/lakehouse/catalogs/private-networking/overview"},{"title":"Private Networking for Snowflake Open Catalog","sidebarTitle":"Snowflake Open Catalog","href":"/cloud/lakehouse/catalogs/private-networking/snowflake-open-catalog"},{"title":"Private Networking for Snowflake Horizon Catalog","sidebarTitle":"Snowflake Horizon Catalog","href":"/cloud/lakehouse/catalogs/private-networking/snowflake-horizon-catalog"},{"title":"Private Networking for Databricks Unity Catalog (Delta Lake)","sidebarTitle":"Databricks Delta Lake","href":"/cloud/lakehouse/catalogs/private-networking/databricks-unity-catalog"},{"title":"Private Networking for Databricks Unity Catalog (Iceberg)","sidebarTitle":"Databricks Iceberg","href":"/cloud/lakehouse/catalogs/private-networking/databricks-iceberg"},{"title":"Private Networking for Amazon S3 Tables","sidebarTitle":"Amazon S3 Tables","href":"/cloud/lakehouse/catalogs/private-networking/s3-tables"},{"title":"Private Networking for Google BigLake","sidebarTitle":"Google BigLake","href":"/cloud/lakehouse/catalogs/private-networking/google-biglake"}]}]},{"title":"Lakehouse Observability","sidebarTitle":"Lakehouse Observability","href":"/cloud/lakehouse/lakehouse-observability"},{"group":"Troubleshooting","pages":[{"title":"Troubleshoot duplicate file references in Unity Catalog","sidebarTitle":"Duplicate file references","href":"/cloud/lakehouse/unity-catalog-duplicate-file-references"}]}]},{"group":"Governance","pages":[{"title":"Kafka Schema Registry","sidebarTitle":"Overview","href":"/kafka/governance/sr/overview"},{"title":"Connect to the Kafka Schema Registry","sidebarTitle":"Connect","href":"/kafka/governance/sr/connect"},{"title":"Kafka Schema Registry Tutorial","sidebarTitle":"Tutorial","href":"/kafka/governance/sr/tutorial"},{"group":"Fundamentals","pages":[{"title":"Kafka Schema Registry Key Concepts","sidebarTitle":"Key Concepts","href":"/kafka/governance/sr/fundamentals/key-concepts"},{"title":"Kafka Schema Evolution and Compatibility","sidebarTitle":"Evolution and Compatibility","href":"/kafka/governance/sr/fundamentals/schema-evolution"},{"title":"Kafka Serializers and Deserializers","sidebarTitle":"Serializers and Deserializers","href":"/kafka/governance/sr/fundamentals/serdes"},{"group":"Schema Formats","pages":[{"title":"Use Avro Schemas","sidebarTitle":"Avro","href":"/kafka/governance/sr/fundamentals/formats/avro"},{"title":"Use Protobuf Schemas","sidebarTitle":"Protobuf","href":"/kafka/governance/sr/fundamentals/formats/protobuf"},{"title":"Use JSON Schemas","sidebarTitle":"JSON Schema","href":"/kafka/governance/sr/fundamentals/formats/json-schema"}]},{"title":"Use Kafka Schema References","sidebarTitle":"Schema References","href":"/kafka/governance/sr/fundamentals/schema-references"},{"title":"Secure Kafka Schema Registry Access","sidebarTitle":"Security","href":"/kafka/governance/sr/fundamentals/security"}]},{"group":"Manage Schemas","pages":[{"title":"Register and Manage Kafka Schemas","sidebarTitle":"Manage Schemas","href":"/kafka/governance/sr/manage/manage-schemas"},{"title":"Delete Kafka Schemas","sidebarTitle":"Delete Schemas","href":"/kafka/governance/sr/manage/delete-schemas"},{"title":"Validate Schema IDs on the Broker","sidebarTitle":"Schema ID Validation","href":"/kafka/governance/sr/manage/schema-id-validation"},{"title":"Set up active-standby replication for Kafka Schema Registry using Universal Linking","sidebarTitle":"Schema Registry Geo-Replication","href":"/cookbook/kafka-schema-registry-geo-replication"}]},{"group":"Reference","pages":[{"title":"Kafka Schema Registry REST API Examples","sidebarTitle":"REST API","href":"/kafka/governance/sr/reference/rest-api"},{"title":"Kafka Schema Registry Client Configuration","sidebarTitle":"Client Configuration","href":"/kafka/governance/sr/reference/client-configuration"},{"title":"Confluent Schema Registry API Compatibility","sidebarTitle":"Confluent Compatibility","href":"/kafka/governance/sr/reference/confluent-compatibility"},{"title":"Troubleshoot the Kafka Schema Registry","sidebarTitle":"Troubleshooting","href":"/kafka/governance/sr/reference/troubleshooting"}]},{"title":"Kafka Schema Registry FAQ","sidebarTitle":"FAQ","href":"/kafka/governance/sr/faq"}]},{"group":"Migrate","pages":[{"title":"Migrate to StreamNative Kafka Service","sidebarTitle":"Migration Guide","href":"/kafka/kafka-migration-guide"}]},{"group":"Kafka Clients","pages":[{"title":"Build Kafka Client Applications on StreamNative Cloud","sidebarTitle":"Overview","href":"/cloud/build/kafka-clients/kafka-on-cloud"},{"group":"Compatibility","pages":[{"title":"Kafka Compatibility Overview","sidebarTitle":"Overview","href":"/cloud/build/kafka-clients/compatibility/kafka-compatibility"},{"title":"Kafka Protocol and Features","sidebarTitle":"Protocol and Features","href":"/cloud/build/kafka-clients/compatibility/kafka-protocol-and-features"}]},{"group":"Quick Starts","pages":[{"title":"Connect to your cluster using the Kafka Java client","sidebarTitle":"Kafka Java","href":"/cloud/build/kafka-clients/quick-starts/cloud-connect-kafka-java"},{"title":"Connect to your cluster using the Kafka Python client","sidebarTitle":"Kafka Python","href":"/cloud/build/kafka-clients/quick-starts/cloud-connect-kafka-python"},{"title":"Connect to your cluster using the Kafka Go client","sidebarTitle":"Kafka Go","href":"/cloud/build/kafka-clients/quick-starts/cloud-connect-kafka-go"},{"title":"Connect to your cluster using the Kafka Node.js client","sidebarTitle":"Kafka Nodejs","href":"/cloud/build/kafka-clients/quick-starts/cloud-connect-kafka-nodejs"},{"title":"Connect to your cluster using the Kafka C client (rdkafka)","sidebarTitle":"Kafka C","href":"/cloud/build/kafka-clients/quick-starts/cloud-connect-kafka-c"},{"title":"Connect to your cluster using Kafka CLI","sidebarTitle":"Kafka CLI","href":"/cloud/build/kafka-clients/quick-starts/cloud-connect-kafka-cli"}]},{"group":"Advanced Features","pages":[{"title":"Multi-Tenancy","sidebarTitle":"Multi Tenancy","href":"/cloud/build/kafka-clients/advanced-features/kafka-multi-tenancy"},{"title":"Kafka Compacted Topic","sidebarTitle":"Compacted Topic","href":"/cloud/build/kafka-clients/advanced-features/kafka-compacted-topic"},{"title":"Kafka Transactions","sidebarTitle":"Transactions","href":"/cloud/build/kafka-clients/advanced-features/kafka-transaction"},{"title":"Interoperability between Apache Kafka and Apache Pulsar","sidebarTitle":"Interoperability","href":"/cloud/build/kafka-clients/advanced-features/interoperability-between-kafka-and-pulsar"}]},{"group":"Configuration","pages":[{"title":"Configuring Kafka Clients","sidebarTitle":"Config Client","href":"/cloud/build/kafka-clients/config/config-kafka-client"},{"title":"Configuring Kafka Consumer","sidebarTitle":"Config Consumer","href":"/cloud/build/kafka-clients/config/config-kafka-consumer"},{"title":"Configuring Kafka Producer","sidebarTitle":"Config Producer","href":"/cloud/build/kafka-clients/config/config-kafka-producer"}]},{"group":"Optimize And Tune","pages":[{"title":"Optimize and Tune Kafka Clients","sidebarTitle":"Overview","href":"/cloud/build/kafka-clients/optimize-and-tune/optimize-kafka-clients"},{"title":"Optimize Kafka Client for Throughput","sidebarTitle":"Throughput","href":"/cloud/build/kafka-clients/optimize-and-tune/optimize-kafka-throughput"},{"title":"Optimize Kafka Client for Latency","sidebarTitle":"Latency","href":"/cloud/build/kafka-clients/optimize-and-tune/optimize-kafka-latency"},{"title":"Optimize Kafka Client for Durability","sidebarTitle":"Durability","href":"/cloud/build/kafka-clients/optimize-and-tune/optimize-kafka-durability"},{"title":"Optimize Kafka Client for Availability","sidebarTitle":"Availability","href":"/cloud/build/kafka-clients/optimize-and-tune/optimize-kafka-availability"}]},{"title":"Kafka Rest API Quickstart","sidebarTitle":"Kafka Rest API","href":"/cloud/build/kafka-clients/kafka-rest-api"},{"title":"Migrating to StreamNative","sidebarTitle":"Migrate","href":"/cloud/build/kafka-clients/migrating-to-streamnative"},{"title":"Test Kafka Protocol as code","sidebarTitle":"Test","href":"/cloud/build/kafka-clients/test-kafka-protocol"},{"group":"Integrations","pages":[{"title":"Connect to your cluster using Lenses","sidebarTitle":"Lenses","href":"/cloud/build/kafka-clients/integrations/cloud-connect-lenses"}]},{"group":"Guides","pages":[{"title":"Connect to StreamNative Cloud Using Kafka Clients","sidebarTitle":"Overview","href":"/clients/kafka-clients/kafka-clients-overview"},{"group":"Java","pages":[{"title":"Kafka Java Client Guide","sidebarTitle":"Guide","description":null,"href":"/clients/kafka-clients/java/kafka-java-client-guide"},{"group":"Tutorial","pages":[{"title":"Introduction","sidebarTitle":"Introduction","href":"/clients/kafka-clients/java/tutorial/kafka-java-introduction"},{"title":"Prerequisites","sidebarTitle":"Prerequisites","description":null,"href":"/clients/kafka-clients/java/tutorial/kafka-java-prerequisites"},{"title":"Create Project","sidebarTitle":"Create Project","href":"/clients/kafka-clients/java/tutorial/kafka-java-create-project"},{"title":"Cluster Setup","sidebarTitle":"Cluster Setup","href":"/clients/kafka-clients/java/tutorial/kafka-java-cluster-setup"},{"title":"Create Topic","sidebarTitle":"Create Topic","href":"/clients/kafka-clients/java/tutorial/kafka-java-create-topic"},{"title":"Build Producer","sidebarTitle":"Build Producer","href":"/clients/kafka-clients/java/tutorial/kafka-java-build-producer"},{"title":"Build Consumer","sidebarTitle":"Build Consumer","href":"/clients/kafka-clients/java/tutorial/kafka-java-build-consumer"},{"title":"Produce Messages","sidebarTitle":"Produce Messages","href":"/clients/kafka-clients/java/tutorial/kafka-java-produce-messages"},{"title":"Consume Messages","sidebarTitle":"Consume Messages","href":"/clients/kafka-clients/java/tutorial/kafka-java-consume-messages"},{"title":"What's Next","sidebarTitle":"What's Next","href":"/clients/kafka-clients/java/tutorial/kafka-java-whats-next"}]}]},{"group":".net","pages":[{"group":"Tutorial","pages":[{"title":"Introduction","sidebarTitle":"Introduction","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-introduction"},{"title":"Prerequisites","sidebarTitle":"Prerequisites","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-prerequisites"},{"title":"Create Project","sidebarTitle":"Create Project","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-create-project"},{"title":"Cluster Setup","sidebarTitle":"Cluster Setup","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-cluster-setup"},{"title":"Create Topic","sidebarTitle":"Create Topic","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-create-topic"},{"title":"Build Producer","sidebarTitle":"Build Producer","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-build-producer"},{"title":"Build Consumer","sidebarTitle":"Build Consumer","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-build-consumer"},{"title":"Produce Messages","sidebarTitle":"Produce Messages","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-produce-messages"},{"title":"Consume Messages","sidebarTitle":"Consume Messages","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages"},{"title":"What's Next","sidebarTitle":"What's Next","href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-whats-next"}]}]},{"group":"C And C++","pages":[{"group":"Tutorial","pages":[{"title":"Introduction","sidebarTitle":"Introduction","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-introduction"},{"title":"Prerequisites","sidebarTitle":"Prerequisites","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-prerequisites"},{"title":"Create Project","sidebarTitle":"Create Project","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-create-project"},{"title":"Cluster Setup","sidebarTitle":"Cluster Setup","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-cluster-setup"},{"title":"Create Topic","sidebarTitle":"Create Topic","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-create-topic"},{"title":"Build Producer","sidebarTitle":"Build Producer","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-build-producer"},{"title":"Build Consumer","sidebarTitle":"Build Consumer","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-build-consumer"},{"title":"Produce Messages","sidebarTitle":"Produce Messages","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-produce-messages"},{"title":"Consume Messages","sidebarTitle":"Consume Messages","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-consume-messages"},{"title":"What's Next","sidebarTitle":"What's Next","href":"/clients/kafka-clients/c-and-c++/tutorial/kafka-c-whats-next"}]}]},{"group":"Go","pages":[{"group":"Tutorial","pages":[{"title":"Introduction","sidebarTitle":"Introduction","href":"/clients/kafka-clients/go/tutorial/kafka-go-introduction"},{"title":"Prerequisites","sidebarTitle":"Prerequisites","href":"/clients/kafka-clients/go/tutorial/kafka-go-prerequisites"},{"title":"Create Project","sidebarTitle":"Create Project","href":"/clients/kafka-clients/go/tutorial/kafka-go-create-project"},{"title":"Cluster Setup","sidebarTitle":"Cluster Setup","href":"/clients/kafka-clients/go/tutorial/kafka-go-cluster-setup"},{"title":"Create Topic","sidebarTitle":"Create Topic","href":"/clients/kafka-clients/go/tutorial/kafka-go-create-topic"},{"title":"Build Producer","sidebarTitle":"Build Producer","href":"/clients/kafka-clients/go/tutorial/kafka-go-build-producer"},{"title":"Build Consumer","sidebarTitle":"Build Consumer","href":"/clients/kafka-clients/go/tutorial/kafka-go-build-consumer"},{"title":"Produce Messages","sidebarTitle":"Produce Messages","href":"/clients/kafka-clients/go/tutorial/kafka-go-produce-messages"},{"title":"Consume Messages","sidebarTitle":"Consume Messages","href":"/clients/kafka-clients/go/tutorial/kafka-go-consume-messages"},{"title":"What's Next","sidebarTitle":"What's Next","href":"/clients/kafka-clients/go/tutorial/kafka-go-whats-next"}]}]},{"group":"Node.js","pages":[{"group":"Tutorial","pages":[{"title":"Introduction","sidebarTitle":"Introduction","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-introduction"},{"title":"Prerequisites","sidebarTitle":"Prerequisites","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-prerequisites"},{"title":"Create Project","sidebarTitle":"Create Project","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-create-project"},{"title":"Cluster Setup","sidebarTitle":"Cluster Setup","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-cluster-setup"},{"title":"Create Topic","sidebarTitle":"Create Topic","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-create-topic"},{"title":"Build Producer","sidebarTitle":"Build Producer","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-build-producer"},{"title":"Build Consumer","sidebarTitle":"Build Consumer","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-build-consumer"},{"title":"Produce Messages","sidebarTitle":"Produce Messages","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-produce-messages"},{"title":"Consume Messages","sidebarTitle":"Consume Messages","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-consume-messages"},{"title":"What's Next","sidebarTitle":"What's Next","href":"/clients/kafka-clients/node.js/tutorial/kafka-js-whats-next"}]}]},{"group":"Python","pages":[{"group":"Tutorial","pages":[{"title":"Introduction","sidebarTitle":"Introduction","href":"/clients/kafka-clients/python/tutorial/kafka-python-introduction"},{"title":"Prerequisites","sidebarTitle":"Prerequisites","href":"/clients/kafka-clients/python/tutorial/kafka-python-prerequisites"},{"title":"Create Project","sidebarTitle":"Create Project","href":"/clients/kafka-clients/python/tutorial/kafka-python-create-project"},{"title":"Cluster Setup","sidebarTitle":"Cluster Setup","href":"/clients/kafka-clients/python/tutorial/kafka-python-cluster-setup"},{"title":"Create Topic","sidebarTitle":"Create Topic","href":"/clients/kafka-clients/python/tutorial/kafka-python-create-topic"},{"title":"Build Producer","sidebarTitle":"Build Producer","href":"/clients/kafka-clients/python/tutorial/kafka-python-build-producer"},{"title":"Build Consumer","sidebarTitle":"Build Consumer","href":"/clients/kafka-clients/python/tutorial/kafka-python-build-consumer"},{"title":"Produce Messages","sidebarTitle":"Produce Messages","href":"/clients/kafka-clients/python/tutorial/kafka-python-produce-messages"},{"title":"Consume Messages","sidebarTitle":"Consume Messages","href":"/clients/kafka-clients/python/tutorial/kafka-python-consume-messages"},{"title":"What's Next","sidebarTitle":"What's Next","href":"/clients/kafka-clients/python/tutorial/kafka-python-whats-next"}]}]},{"group":"Spring Boot","pages":[{"group":"Tutorial","pages":[{"title":"Introduction","sidebarTitle":"Introduction","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-introduction"},{"title":"Prerequisites","sidebarTitle":"Prerequisites","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-prerequisites"},{"title":"Create Project","sidebarTitle":"Create Project","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-create-project"},{"title":"Cluster Setup","sidebarTitle":"Cluster Setup","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-cluster-setup"},{"title":"Create Topic","sidebarTitle":"Create Topic","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-create-topic"},{"title":"Build Producer","sidebarTitle":"Build Producer","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-build-producer"},{"title":"Build Consumer","sidebarTitle":"Build Consumer","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-build-consumer"},{"title":"Produce Messages","sidebarTitle":"Produce Messages","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-produce-messages"},{"title":"Consume Messages","sidebarTitle":"Consume Messages","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-consume-messages"},{"title":"What's Next","sidebarTitle":"What's Next","href":"/clients/kafka-clients/spring-boot/tutorial/kafka-spring-boot-whats-next"}]}]}]}]}]},{"tab":"SQL","pages":[{"title":"SQL","href":"/sql/overview/architecture"}]},{"tab":"Agent Engine","pages":[{"title":"Agent Engine","href":"/agent-engine/agents-overview"}]},{"tab":"Admin","pages":[{"title":"Admin","href":"/cloud/clusters/byoc/byoc-overview"}]},{"tab":"Resources","icon":"book-open","menu":[{"item":"API References","icon":"code","pages":[{"title":"API References","href":"/api-references/cloudapi/cloud-api"}]},{"item":"Connectors (Hub)","icon":"puzzle-piece","pages":[{"title":"Connectors (Hub)","href":"/connect/overview"}]},{"item":"Universal Linking","icon":"link","pages":[{"title":"Universal Linking","href":"/cloud/universal-linking/unilink-overview"}]},{"item":"Cookbooks","icon":"utensils-crossed","pages":[{"title":"Cookbooks","href":"/cookbook"}]},{"item":"Release Notes","icon":"list-check","pages":[{"title":"Release Notes","href":"/release-notes/cloud/release-notes"}]},{"item":"Support","icon":"headset","pages":[{"title":"Support","href":"/support/get-support"}]}],"pages":[{"title":"Resources","href":"/api-references/cloudapi/cloud-api"}]}]},{"product":"StreamNative Private Cloud","icon":"server","description":"Self-managed on Kubernetes","pages":[{"title":"StreamNative Private Cloud","href":"/private-cloud/home"}]}]},"title":"Introduction - StreamNative Documentation","buildId":"dpl_2oYXwqkEXirXBPk8wV1FtM5USFWi","deploymentId":"dpl_2oYXwqkEXirXBPk8wV1FtM5USFWi","dynamics":[],"chunks":[]}