1"use strict";(self.webpackChunkconduit_site=self.webpackChunkconduit_site||[]).push([[3777],{8744:(e,n,t)=>{t.r(n),t.d(n,{assets:()=>m,contentTitle:()=>p,default:()=>g,frontMatter:()=>h,metadata:()=>o,toc:()=>b});const o=JSON.parse('{"id":"using/connectors/list/rabbitmq","title":"rabbitmq","description":"A RabbitMQ source and destination plugin for Conduit, written in Go.","source":"@site/docs/1-using/5-connectors/7-list/49-rabbitmq.mdx","sourceDirName":"1-using/5-connectors/7-list","slug":"/using/connectors/list/rabbitmq","permalink":"/docs/using/connectors/list/rabbitmq","draft":false,"unlisted":false,"editUrl":"https://github.com/conduitio/conduitio.github.io/edit/main/docs/1-using/5-connectors/7-list/49-rabbitmq.mdx","tags":[],"version":"current","lastUpdatedAt":1751449016000,"sidebarPosition":49,"frontMatter":{"IMPORTANT":"This file was generated using src/connectorgen/main.go. DO NOT EDIT.","title":"rabbitmq","description":"A RabbitMQ source and destination plugin for Conduit, written in Go."},"sidebar":"docsSidebar","previous":{"title":"mysql","permalink":"/docs/using/connectors/list/mysql"},"next":{"title":"snowflake","permalink":"/docs/using/connectors/list/snowflake"}}');var r=t(74848),i=t(28453),a=(t(82514),t(44744)),s=t(96300),c=(t(11470),t(19365),t(43294)),l=t(55281),d=t(9257),u=t(91922);const h={IMPORTANT:"This file was generated using src/connectorgen/main.go. DO NOT EDIT.",title:"rabbitmq",description:"A RabbitMQ source and destination plugin for Conduit, written in Go."},p="rabbitmq",m={},b=[{value:"Latest release",id:"latest-release",level:2},{value:"Description",id:"description",level:2},{value:"Source Parameters",id:"source-parameters",level:2},{value:"Destination Parameters",id:"destination-parameters",level:2}];function f(e){const n={a:"a",code:"code",h1:"h1",h2:"h2",header:"header",li:"li",p:"p",pre:"pre",ul:"ul",...(0,i.R)(),...e.components};return(0,r.jsxs)(r.Fragment,{children:[(0,r.jsx)(n.header,{children:(0,r.jsx)(n.h1,{id:"rabbitmq",children:"rabbitmq"})}),"\n",(0,r.jsxs)(s.A,{sx:{display:"flex",alignItems:"center",gap:2,marginBottom:4,borderRadius:1,padding:2,backgroundColor:"rgba(0, 0, 0, 0.03)"},children:[(0,r.jsxs)(s.A,{sx:{display:"flex",alignItems:"center",gap:1},children:[(0,r.jsx)("span",{children:"Author: Meroxa, Inc."}),(0,r.jsx)(u.A,{title:"Created by the Conduit team",children:(0,r.jsx)("img",{src:"/img/conduit/conduit-ring.png",width:"18",alt:"Conduit team logo"})})]}),(0,r.jsx)(s.A,{sx:{borderLeft:"1px solid rgba(0, 0, 0, 0.12)",height:24}}),(0,r.jsx)(l.A,{href:"https://github.com/conduitio-labs/conduit-connector-rabbitmq",target:"_blank",sx:{display:"flex",alignItems:"center",gap:.5,color:"inherit",textDecoration:"none","&:hover":{textDecoration:"underline"}},children:(0,r.jsx)(c.A,{sx:{fontSize:"1.5rem"}})}),(0,r.jsx)(a.A,{icon:(0,r.jsx)(d.A,{sx:{fontSize:"1rem"}}),label:"0",size:"small",sx:{height:24}})]}),"\n",(0,r.jsx)(n.h2,{id:"latest-release",children:"Latest release"}),"\n",(0,r.jsxs)(n.ul,{children:["\n",(0,r.jsx)(n.li,{children:(0,r.jsx)(n.a,{href:"https://conduit.gateway.scarf.sh/connector/download/conduitio-labs/conduit-connector-rabbitmq/releases/download/v0.4.0/conduit-connector-rabbitmq_0.4.0_Darwin_arm64.tar.gz",children:"conduit-connector-rabbitmq_0.4.0_Darwin_arm64.tar.gz"})}),"\n",(0,r.jsx)(n.li,{children:(0,r.jsx)(n.a,{href:"https://conduit.gateway.scarf.sh/connector/download/conduitio-labs/conduit-connector-rabbitmq/releases/download/v0.4.0/conduit-connector-rabbitmq_0.4.0_Darwin_x86_64.tar.gz",children:"conduit-connector-rabbitmq_0.4.0_Darwin_x86_64.tar.gz"})}),"\n",(0,r.jsx)(n.li,{children:(0,r.jsx)(n.a,{href:"https://conduit.gateway.scarf.sh/connector/download/conduitio-labs/conduit-connector-rabbitmq/releases/download/v0.4.0/conduit-connector-rabbitmq_0.4.0_Linux_arm64.tar.gz",children:"conduit-connector-rabbitmq_0.4.0_Linux_arm64.tar.gz"})}),"\n",(0,r.jsx)(n.li,{children:(0,r.jsx)(n.a,{href:"https://conduit.gateway.scarf.sh/connector/download/conduitio-labs/conduit-connector-rabbitmq/releases/download/v0.4.0/conduit-connector-rabbitmq_0.4.0_Linux_i386.tar.gz",children:"conduit-connector-rabbitmq_0.4.0_Linux_i386.tar.gz"})}),"\n",(0,r.jsx)(n.li,{children:(0,r.jsx)(n.a,{href:"https://conduit.gateway.scarf.sh/connector/download/conduitio-labs/conduit-connector-rabbitmq/releases/download/v0.4.0/conduit-connector-rabbitmq_0.4.0_Linux_x86_64.tar.gz",children:"conduit-connector-rabbitmq_0.4.0_Linux_x86_64.tar.gz"})}),"\n",(0,r.jsx)(n.li,{children:(0,r.jsx)(n.a,{href:"https://conduit.gateway.scarf.sh/connector/download/conduitio-labs/conduit-connector-rabbitmq/releases/download/v0.4.0/conduit-connector-rabbitmq_0.4.0_Windows_arm64.tar.gz",children:"conduit-connector-rabbitmq_0.4.0_Windows_arm64.tar.gz"})}),"\n",(0,r.jsx)(n.li,{children:(0,r.jsx)(n.a,{href:"https://conduit.gateway.scarf.sh/connector/download/conduitio-labs/conduit-connector-rabbitmq/releases/download/v0.4.0/conduit-connector-rabbitmq_0.4.0_Windows_i386.tar.gz",children:"conduit-connector-rabbitmq_0.4.0_Windows_i386.tar.gz"})}),"\n",(0,r.jsx)(n.li,{children:(0,r.jsx)(n.a,{href:"https://conduit.gateway.scarf.sh/connector/download/conduitio-labs/conduit-connector-rabbitmq/releases/download/v0.4.0/conduit-connector-rabbitmq_0.4.0_Windows_x86_64.tar.gz",children:"conduit-connector-rabbitmq_0.4.0_Windows_x86_64.tar.gz"})}),"\n"]}),"\n",(0,r.jsx)(n.h2,{id:"description",children:"Description"}),"\n",(0,r.jsx)(n.p,{children:"A RabbitMQ source and destination plugin for Conduit, written in Go."}),"\n",(0,r.jsx)(n.h2,{id:"source-parameters",children:"Source Parameters"}),"\n",(0,r.jsx)(n.pre,{children:(0,r.jsx)(n.code,{className:"language-yaml",children:'version: 2.2\npipelines:\n - id: example\n status: running\n connectors:\n - id: example-source\n type: source\n plugin: "rabbitmq"\n name: example-source\n settings:\n # The name of the queue to consume from / publish to\n # Type: string\n queue.name: ""\n # The RabbitMQ server URL\n # Type: string\n url: ""\n # Indicates if the server should consider messages acknowledged once\n # delivered.\n # Type: bool\n consumer.autoAck: "false"\n # Indicates if the consumer should be exclusive.\n # Type: bool\n consumer.exclusive: "false"\n # The name of the consumer\n # Type: string\n consumer.name: ""\n # Indicates if the server should not deliver messages published by the\n # same connection.\n # Type: bool\n consumer.noLocal: "false"\n # Indicates if the consumer should be declared without waiting for\n # server confirmation.\n # Type: bool\n consumer.noWait: "false"\n # Indicates if the queue will be deleted when there are no more\n # consumers.\n # Type: bool\n queue.autoDelete: "false"\n # Indicates if the queue will survive broker restarts.\n # Type: bool\n queue.durable: "true"\n # Indicates if the queue can be accessed by other connections.\n # Type: bool\n queue.exclusive: "false"\n # Indicates if the queue should be declared without waiting for server\n # confirmation.\n # Type: bool\n queue.noWait: "false"\n # Skips queue declare call assuming that it already exists.\n # Type: bool\n queue.skipDeclare: "false"\n # The path to the CA certificate to use for TLS\n # Type: string\n tls.caCert: ""\n # The path to the client certificate to use for TLS\n # Type: string\n tls.clientCert: ""\n # The path to the client key to use for TLS\n # Type: string\n tls.clientKey: ""\n # Indicates if TLS should be used\n # Type: bool\n tls.enabled: "fal
1se"\n # Maximum delay before an incomplete batch is read from the source.\n # Type: duration\n sdk.batch.delay: "0"\n # Maximum size of batch before it gets read from the source.\n # Type: int\n sdk.batch.size: "0"\n # Specifies whether to use a schema context name. If set to false, no\n # schema context name will be used, and schemas will be saved with the\n # subject name specified in the connector (not safe because of name\n # conflicts).\n # Type: bool\n sdk.schema.context.enabled: "true"\n # Schema context name to be used. Used as a prefix for all schema\n # subject names. If empty, defaults to the connector ID.\n # Type: string\n sdk.schema.context.name: ""\n # Whether to extract and encode the record key with a schema.\n # Type: bool\n sdk.schema.extract.key.enabled: "true"\n # The subject of the key schema. If the record metadata contains the\n # field "opencdc.collection" it is prepended to the subject name and\n # separated with a dot.\n # Type: string\n sdk.schema.extract.key.subject: "key"\n # Whether to extract and encode the record payload with a schema.\n # Type: bool\n sdk.schema.extract.payload.enabled: "true"\n # The subject of the payload schema. If the record metadata contains\n # the field "opencdc.collection" it is prepended to the subject name\n # and separated with a dot.\n # Type: string\n sdk.schema.extract.payload.subject: "payload"\n # The type of the payload schema.\n # Type: string\n sdk.schema.extract.type: "avro"\n'})}),"\n",(0,r.jsx)(n.h2,{id:"destination-parameters",children:"Destination Parameters"}),"\n",(0,r.jsx)(n.pre,{children:(0,r.jsx)(n.code,{className:"language-yaml",children:'version: 2.2\npipelines:\n - id: example\n status: running\n connectors:\n - id: example-destination\n type: destination\n plugin: "rabbitmq"\n name: example-destination\n settings:\n # The name of the queue to consume from / publish to\n # Type: string\n queue.name: ""\n # The RabbitMQ server URL\n # Type: string\n url: ""\n # The application that created the message.\n # Type: string\n delivery.appID: ""\n # The encoding of the message content.\n # Type: string\n delivery.contentEncoding: ""\n # The MIME type of the message content. Defaults to\n # "application/json".\n # Type: string\n delivery.contentType: "application/json"\n # The correlation ID used to correlate RPC responses with requests.\n # Type: string\n delivery.correlationID: ""\n # The message delivery mode. Non-persistent (1) or persistent (2).\n # Default is 2 (persistent).\n # Type: int\n delivery.deliveryMode: "2"\n # The message expiration time, if any.\n # Type: string\n delivery.expiration: ""\n # Indicates if the message should be treated as immediate. If true,\n # the message is not queued if no consumers are on the matching queue.\n # Type: bool\n delivery.immediate: "false"\n # Indicates if the message is mandatory. If true, tells the server to\n # return the message if it cannot be routed to a queue.\n # Type: bool\n delivery.mandatory: "false"\n # The message type name.\n # Type: string\n delivery.messageTypeName: ""\n # The message priority. Ranges from 0 to 9. Default is 0.\n # Type: int\n delivery.priority: "0"\n # The address to reply to.\n # Type: string\n delivery.replyTo: ""\n # The user who created the message. Useful for publishers.\n # Type: string\n delivery.userID: ""\n # Indicates if the exchange will be deleted when the last queue is\n # unbound from it.\n # Type: bool\n exchange.autoDelete: "false"\n # Indicates if the exchange will survive broker restarts.\n # Type: bool\n exchange.durable: "true"\n # Indicates if the exchange is used for internal purposes and cannot\n # be directly published to by a client.\n # Type: bool\n exchange.
1internal: "false"\n # The name of the exchange.\n # Type: string\n exchange.name: ""\n # Indicates if the exchange should be declared without waiting for\n # server confirmation.\n # Type: bool\n exchange.noWait: "false"\n # Skips exchange declare call assuming that it already exists.\n # Type: bool\n exchange.skipDeclare: "false"\n # The type of the exchange (e.g., direct, fanout, topic, headers).\n # Type: string\n exchange.type: ""\n # Indicates if the queue will be deleted when there are no more\n # consumers.\n # Type: bool\n queue.autoDelete: "false"\n # Indicates if the queue will survive broker restarts.\n # Type: bool\n queue.durable: "true"\n # Indicates if the queue can be accessed by other connections.\n # Type: bool\n queue.exclusive: "false"\n # Indicates if the queue should be declared without waiting for server\n # confirmation.\n # Type: bool\n queue.noWait: "false"\n # Skips queue declare call assuming that it already exists.\n # Type: bool\n queue.skipDeclare: "false"\n # The routing key to use when publishing to an exchange\n # Type: string\n routingKey: "{{ index .Metadata "rabbitmq.routingKey" }}"\n # The path to the CA certificate to use for TLS\n # Type: string\n tls.caCert: ""\n # The path to the client certificate to use for TLS\n # Type: string\n tls.clientCert: ""\n # The path to the client key to use for TLS\n # Type: string\n tls.clientKey: ""\n # Indicates if TLS should be used\n # Type: bool\n tls.enabled: "false"\n # Maximum delay before an incomplete batch is written to the\n # destination.\n # Type: duration\n sdk.batch.delay: "0"\n # Maximum size of batch before it gets written to the destination.\n # Type: int\n sdk.batch.size: "0"\n # Allow bursts of at most X records (0 or less means that bursts are\n # not limited). Only takes effect if a rate limit per second is set.\n # Note that if `sdk.batch.size` is bigger than `sdk.rate.burst`, the\n # effective batch size will be equal to `sdk.rate.burst`.\n # Type: int\n sdk.rate.burst: "0"\n # Maximum number of records written per second (0 means no rate\n # limit).\n # Type: float\n sdk.rate.perSecond: "0"\n # The format of the output record. See the Conduit documentation for a\n # full list of supported formats\n # (https://conduit.io/docs/using/connectors/configuration-parameters/output-format).\n # Type: string\n sdk.record.format: "opencdc/json"\n # Options to configure the chosen output record format. Options are\n # normally key=value pairs separated with comma (e.g.\n # opt1=val2,opt2=val2), except for the `template` record format, where\n # options are a Go template.\n # Type: string\n sdk.record.format.options: ""\n # Whether to extract and decode the record key with a schema.\n # Type: bool\n sdk.schema.extract.key.enabled: "true"\n # Whether to extract and decode the record payload with a schema.\n # Type: bool\n sdk.schema.extract.payload.enabled: "true"\n'})})]})}function g(e={}){const{wrapper:n}={...(0,i.R)(),...e.components};return n?(0,r.jsx)(n,{...e,children:(0,r.jsx)(f,{...e})}):f(e)}},55281:(e,n,t)=>{t.d(n,{A:()=>_});var o=t(98587),r=t(58168),i=t(96540),a=t(34164),s=t(75659),c=t(28466),l=t(11848),d=t(46126),u=t(60458),h=t(96852),p=t(47859),m=t(38413),b=t(31609);function f(e){return(0,b.Ay)("MuiLink",e)}const g=(0,m.A)("MuiLink",["root","underlineNone","underlineHover","underlineAlways","button","focusVisible"]);var y=t(86481),x=t(771);const T={primary:"primary.main",textPrimary:"text.primary",secondary:"secondary.main",textSecondary:"text.secondary",error:"error.main"},w=({theme:e,ownerState:n})=>{const t=(e=>T[e]||e)(n.color),o=(0,y.Yn)(e,`palette.${t}`,!1)||n.color,r=(0,y.Yn)(e,`palette.${t}Channel`);return"vars"in e&&r?`rgba(${r} / 0.4)`:(0,x.X4)(o,.4)};
1var v=t(74848);const q=["className","color","component","onBlur","onFocus","TypographyClasses","underline","variant","sx"],k=(0,l.Ay)(p.A,{name:"MuiLink",slot:"Root",overridesResolver:(e,n)=>{const{ownerState:t}=e;return[n.root,n[`underline${(0,c.A)(t.underline)}`],"button"===t.component&&n.button]}})(({theme:e,ownerState:n})=>(0,r.A)({},"none"===n.underline&&{textDecoration:"none"},"hover"===n.underline&&{textDecoration:"none","&:hover":{textDecoration:"underline"}},"always"===n.underline&&(0,r.A)({textDecoration:"underline"},"inherit"!==n.color&&{textDecorationColor:w({theme:e,ownerState:n})},{"&:hover":{textDecorationColor:"inherit"}}),"button"===n.component&&{position:"relative",WebkitTapHighlightColor:"transparent",backgroundColor:"transparent",outline:0,border:0,margin:0,borderRadius:0,padding:0,cursor:"pointer",userSelect:"none",verticalAlign:"middle",MozAppearance:"none",WebkitAppearance:"none","&::-moz-focus-inner":{borderStyle:"none"},[`&.${g.focusVisible}`]:{outline:"auto"}})),_=i.forwardRef(function(e,n){const t=(0,d.b)({props:e,name:"MuiLink"}),{className:l,color:p="primary",component:m="a",onBlur:b,onFocus:g,TypographyClasses:y,underline:x="always",variant:w="inherit",sx:_}=t,j=(0,o.A)(t,q),{isFocusVisibleRef:A,onBlur:I,onFocus:D,ref:S}=(0,u.A)(),[z,C]=i.useState(!1),M=(0,h.A)(n,S),L=(0,r.A)({},t,{color:p,component:m,focusVisible:z,underline:x,variant:w}),R=(e=>{const{classes:n,component:t,focusVisible:o,underline:r}=e,i={root:["root",`underline${(0,c.A)(r)}`,"button"===t&&"button",o&&"focusVisible"]};return(0,s.A)(i,f,n)})(L);return(0,v.jsx)(k,(0,r.A)({color:p,className:(0,a.A)(R.root,l),classes:y,component:m,onBlur:e=>{I(e),!1===A.current&&C(!1),b&&b(e)},onFocus:e=>{D(e),!0===A.current&&C(!0),g&&g(e)},ref:M,ownerState:L,variant:w,sx:[...Object.keys(T).includes(p)?[]:[{color:p}],...Array.isArray(_)?_:[_]]},j))})}}]);
Line numbers count LF bytes from the start of the resource, as the search results do. Vendor segments are library code the classifier recognised; they are stored but not indexed. Bytes are shown as Latin1 characters, one per byte.