From another terminal, run the following command to run the consumer application which will read the events from the purchases topic and write the information to the terminal.
cd consumerdotnet run
The consumer application will start and print any events it has not yet consumed and then wait for more events to arrive. On startup of the consumer, you should see output resembling this:
Consumed event from topic purchases: key = jsmith value = gift cardConsumed event from topic purchases: key = awalther value = batteriesConsumed event from topic purchases: key = awalther value = gift cardConsumed event from topic purchases: key = awalther value = bookConsumed event from topic purchases: key = htanaka value = bookConsumed event from topic purchases: key = sgarcia value = gift cardConsumed event from topic purchases: key = sgarcia value = t-shirtsConsumed event from topic purchases: key = sgarcia value = gift cardConsumed event from topic purchases: key = sgarcia value = bookConsumed event from topic purchases: key = sgarcia value = gift card
Rerun the producer to see more events, or feel free to modify the code as necessary to create more or different events.Once you are done, enter Ctrl-C to terminate the consumer application.
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":"6ae45bffae091ec13e31d87b","collectionId":"07830b93-a0c4-4f14-94c0-128b8b518c4e","schemaVersion":"v3","latestBuiltDeploymentHistoryId":"6ae45bffae091ec13e31d87b"},"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":"6ae45bffae091ec13e31d87b","clientVersion":"0.0.4039","searchFilterCounts":[{"language":"default","tag":"StreamNative Cloud","count":814},{"language":"default","tag":"Pulsar","count":665},{"language":"default","tag":"StreamNative Private Cloud","count":300},{"language":"default","tag":"Pulsar Changelogs","count":273},{"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":"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":"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":"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":"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":"billing-page-v2","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":false},{"name":"full-page-search","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":"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},{"name":"approve-review-flow","enabled":true,"variant":{"name":"disabled","enabled":false,"feature_enabled":true},"impressionData":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/.net/tutorial/kafka-dotnet-consume-messages","slug":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages","pageMetadata":{"title":"Consume Messages","id":"kafka-dotnet-consume-messages","category":"get-started","redirects":null,"tags":["get started","Kafka",".NET"],"sidebarTitle":"Consume Messages","description":null,"href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages"},"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={code:`code`,p:`p`,pre:`pre`,span:`span`,..._provideComponents(),...props.components},{CodeBlock}=_components;if(!CodeBlock)_missingMdxReference(`CodeBlock`,true);return _jsxs(_Fragment,{children:[_jsxs(_components.p,{children:[`From another terminal, run the following command to run the consumer application which will read the events from the `,_jsx(_components.code,{children:`purchases`}),` topic and write the information to the terminal.`]}),`\n`,_jsx(CodeBlock,{filename:``,numberOfLines:`2`,language:`shellscript`,children:_jsx(_components.pre,{className:`shiki shiki-themes github-light-default dark-plus`,style:{backgroundColor:`#ffffff`,\"--shiki-dark-bg\":`#0B0C0E`,color:`#1f2328`,\"--shiki-dark\":`#D4D4D4`},language:`shellscript`,children:_jsxs(_components.code,{language:`shellscript`,numberOfLines:`2`,children:[_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#0550AE`,\"--shiki-dark\":`#DCDCAA`},children:`cd`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` consumer`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`dotnet`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` run`})]}),`\n`]})})}),`\n`,_jsx(_components.p,{children:`The consumer application will start and print any events it has not yet consumed and then wait for more events to arrive. On startup of the consumer, you should see output resembling this:`}),`\n`,_jsx(CodeBlock,{filename:``,numberOfLines:`10`,language:`shellscript`,children:_jsx(_components.pre,{className:`shiki shiki-themes github-light-default dark-plus`,style:{backgroundColor:`#ffffff`,\"--shiki-dark-bg\":`#0B0C0E`,color:`#1f2328`,\"--shiki-dark\":`#D4D4D4`},language:`shellscript`,children:_jsxs(_components.code,{language:`shellscript`,numberOfLines:`10`,children:[_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` jsmith`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` gift`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` card`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` awalther`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` batteries`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` awalther`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` gift`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` card`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` awalther`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` book`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` htanaka`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` book`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` sgarcia`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` gift`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` card`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` sgarcia`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` t-shirts`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` sgarcia`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` gift`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` card`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` sgarcia`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` book`})]}),`\n`,_jsxs(_components.span,{className:`line`,children:[_jsx(_components.span,{style:{color:`#953800`,\"--shiki-dark\":`#DCDCAA`},children:`Consumed`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` event`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` from`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` topic`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` purchases:`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` key`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` sgarcia`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` value`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` =`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` gift`}),_jsx(_components.span,{style:{color:`#0A3069`,\"--shiki-dark\":`#CE9178`},children:` card`})]}),`\n`]})})}),`\n`,_jsx(_components.p,{children:`Rerun the producer to see more events, or feel free to modify the code as necessary to create more or different events.`}),`\n`,_jsxs(_components.p,{children:[`Once you are done, enter `,_jsx(_components.code,{children:`Ctrl-C`}),` to terminate the consumer application.`]})]})}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":"Consume Messages","id":"kafka-dotnet-consume-messages","category":"get-started","redirects":null,"tags":["get started","Kafka",".NET"],"sidebarTitle":"Consume Messages","description":null,"href":"/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages"}}},"mdxSourceWithNoJs":null},"mdxExtracts":{"tableOfContents":[],"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":"Consume Messages - StreamNative Documentation","navMaps":{"firstHrefInVersion":{},"firstHrefInLanguage":{}},"lastModified":"2026-10-30T08:58:06.877Z","originalFileLocation":"clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages.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=\"Consume Messages - 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/.net/tutorial/kafka-dotnet-consume-messages\">\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=\"Consume Messages - 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/.net/tutorial/kafka-dotnet-consume-messages\">\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/.net/tutorial/kafka-dotnet-consume-messages.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/.net/tutorial/kafka-dotnet-consume-messages#webpage\",\"url\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages\",\"name\":\"Consume Messages\",\"dateModified\":\"2026-10-30T08:58:06.877Z\",\"isPartOf\":{\"@id\":\"https://docs.streamnative.io#website\"},\"breadcrumb\":{\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages#breadcrumb\"}},{\"@type\":\"BreadcrumbList\",\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages#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\":\".net\",\"item\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-introduction\"},{\"@type\":\"ListItem\",\"position\":4,\"name\":\"Tutorial\",\"item\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-introduction\"},{\"@type\":\"ListItem\",\"position\":5,\"name\":\"Consume Messages\",\"item\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages\"}]},{\"@type\":[\"Article\",\"TechArticle\"],\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages#article\",\"headline\":\"Consume Messages\",\"name\":\"Consume Messages\",\"url\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages\",\"mainEntityOfPage\":{\"@id\":\"https://docs.streamnative.io/clients/kafka-clients/.net/tutorial/kafka-dotnet-consume-messages#webpage\"},\"image\":\"https://docs.streamnative.io/logo/light.svg\",\"dateModified\":\"2026-10-30T08:58:06.877Z\",\"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","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","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","description":null,"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","description":null,"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/v2/overview/private-cloud-overview"}]}]},"basePath":"","title":"Consume Messages - StreamNative Documentation","buildId":"dpl_77Hw7ZuAABM8E3WMbYAf2ohQCr3v","deploymentId":"dpl_77Hw7ZuAABM8E3WMbYAf2ohQCr3v","dynamics":[],"chunks":[]}