https://tidbcloud.com/static/js/async/1811.893e9e15.js

1"use strict";(globalThis.webpackChunktidb_cloud_ui=globalThis.webpackChunktidb_cloud_ui||[]).push([["1811"],{275771:function(e,n,t){t.d(n,{e:()=>r});function r(e){if(!e)return e;let{content_compatible:n,...t}=e;return{...t,..."S3_PROTOCOL_CANAL_JSON"===e.protocol&&void 0!==n?{content_compatible:n}:{}}}},204785:function(e,n,t){t.d(n,{R:()=>r});function r(e){try{return new Date(1e3*Number(BigInt(e)/1000n>>18n))}catch{return null}}},670418:function(e,n,t){t.d(n,{Z:()=>d});var r=t(275271),l=t(381674),a=t(294859),i=t(807079),s=t(597735),o=t(918853);function d(e,n,t=!0){var c,u;let p=(0,s.i)(e),[h,x]=(0,r.useState)(!1),[v,E]=(0,r.useState)(),m=(0,r.useRef)(!1),g=(0,o.T)(!!n),_=(0,l.useQuery)(["changefeed-editor-checkpoint",e,n],()=>p.get(n),{enabled:!!n,refetchInterval:5e3,refetchOnWindowFocus:!0,retry:!1});return{busy:h,error:v,disabledReason:t?_.isError?"Unable to verify the checkpoint. Refresh and try again.":_.isLoading?"Checking the current checkpoint...":(0,i.$Z)(_.data,g)||((null===(c=_.data)||void 0===c?void 0:c.status)==="PAUSED"||(0,i.zR)(null===(u=_.data)||void 0===u?void 0:u.status)?void 0:"The changefeed must be paused or failed before saving and resuming."):"You do not have permission to update this changefeed.",save:async(e,r)=>{if(m.current||!t||!n)return!1;m.current=!0,x(!0),E(void 0);try{return r?await (0,i.i3)(p,n,e):await e(),!0}catch(e){return E(e instanceof Error?e.message:(0,a.e$)(e)),_.refetch(),!1}finally{m.current=!1,x(!1)}}}}},256762:function(e,n,t){t.d(n,{C9:()=>v,Ez:()=>S,HG:()=>h,Nc:()=>f,P5:()=>N,W$:()=>I,X2:()=>x,Y$:()=>g,ZX:()=>m,_j:()=>A,g8:()=>E,gD:()=>U,lm:()=>j,q3:()=>C,sl:()=>b,ye:()=>_});var r,l,a=t(859224),i=t(286321),s=t(875173),o=t(607212),d=t(883452),c=t(375661),u=t(813587),p=t(980080);let h={[c.g.CANCELED]:"carbon",[c.g.CANCELING]:"carbon",[c.g.COMPLETED]:"green",[c.g.FAILED]:"red",[c.g.IMPORTING]:"peacock",[c.g.PREPARING]:"carbon",[c.g.UNKNOWN]:"carbon",[u.L.ENUM_UNSPECIFIED]:"carbon",[u.L.ENUM_PREPARING]:"carbon",[u.L.ENUM_IMPORTING]:"peacock",[u.L.ENUM_COMPLETED]:"green",[u.L.ENUM_FAILED]:"red",[u.L.ENUM_CANCELING]:"carbon",[u.L.ENUM_CANCELED]:"carbon",[u.L.ENUM_SCALING_UP]:"carbon"},x={[a.d.CANCELED]:"carbon",[a.d.FAILED]:"red",[a.d.DELETED]:"carbon",[a.d.EXPIRED]:"carbon",[a.d.RUNNING]:"peacock",[a.d.SUCCEEDED]:"green"},v=e=>[c.g.UNKNOWN,c.g.PREPARING,c.g.IMPORTING].includes(e),E=e=>[i.n.PREPARING,i.n.IMPORTING].includes(e);var m=((r={})[r.sql_file=1]="sql_file",r[r.aurora=2]="aurora",r[r.csv=3]="csv",r[r.parquet=4]="parquet",r);let g={1:"SQL",2:"Aurora Snapshot",3:"CSV",4:"Parquet",[s.P.SQL]:"SQL",[s.P.AURORA_SNAPSHOT]:"Aurora Snapshot",[s.P.CSV]:"CSV",[s.P.PARQUET]:"Parquet"};var _=((l={})[l.aws=1]="aws",l[l.gcs=2]="gcs",l[l.local=3]="local",l[l.azure=4]="azure",l[l.aliyun=5]="aliyun",l);let f={1:"Amazon S3",2:"Google Cloud Storage",3:"Local file",4:"Azure Blob Storage",5:"Alibaba Cloud OSS",[o.l.LOCAL]:"Local file",[o.l.S3]:"Amazon S3",[o.l.GCS]:"Google Cloud Storage",[o.l.AZURE_BLOB]:"Azure Blob Storage",[o.l.OSS]:"Alibaba Cloud OSS"},j={2:".parquet",3:".csv",1:".sql",4:".parquet",[s.P.SQL]:".sql",[s.P.AURORA_SNAPSHOT]:".parquet",[s.P.CSV]:".csv",[s.P.PARQUET]:".parquet"},b={separator:",",delimiter:'"',header:!0,not_null:!1,null:"\\N",backslash_escape:!0,trim_last_separator:!1},S=(e,n,t=3)=>{let r="single"===n?`/data${j[t]}`:"/";return 4===e?`https://myaccount.blob.core.windows.net/mycontainer/data-ingestion${r}`:`${1===e?"s3":2===e?"gs":5===e?"oss":"https"}://tidbcloud-samples/data-ingestion${r}`},N=e=>{if(e===o.l.AZURE_BLOB)return"https://myaccount.blob.core.windows.net/mycontainer/data-ingestion/";let n="tidbcloud-samples/data-ingestion/";return e===o.l.S3||e===p.s.ENUM_S3?`s3://${n}`:e===o.l.GCS?`gs://${n}`:e===o.l.OSS||e===p.s.ENUM_OSS?`oss://${n}`:`https://${n}`},A=[{label:"Local File",value:d.r.LOCAL,key:"local"},{label:"Alibaba Cloud OSS",value:d.r.OSS,key:"oss"},{label:"Amazon S3",value:d.r.S3,key:"s3"},{label:"Google Cloud Storage",value:d.r.GCS,key:"gcs"},{label:"Azure Blob Storage",value:d.r.AZURE_BLOB,key:"azure_blob"}],U=`https://portal.azure.com/#create/Microsoft.Template/uri/${encodeURIComponent("https://tcidm.blob.core.windows.net/template/sas-token-template.json?sp=r&st=2025-01-15T07:38:59Z&se=2099-01-15T15:38:59Z&spr=https&sv=2022-11-02&sr=b&sig=msCJ%2Fs2aUjJETQcplXb9fsmEGxT2DWVvvH%2F4gQ5XsX8%3D")}`,C=`https://portal.azure.com/#create/Microsoft.Template/uri/${encodeURIComponent("https://tidbserverless.blob.core.windows.net/serverless-template/sas-token-import-template.json")}`,I=`https://portal.azure.com/#create/Microsoft.Template/uri/${encodeURIComponent("https://tidbserverless.blob.core.windows.net/serverless-template/sas-token-export-template.json")}`},120110:function(e,n,t){t.d(n,{_s:()=>l,n2:()=>a});var r=t(256762);let l=e=>40!==e.length?"It should have 40 characters":!!/^[0-9a-zA-z+/]{40}$/.test(e)||"It should consist of '+', '/', numbers and letters only",a=(e,n)=>{let t=e.trim(),{sourceType:l,directory:a,format:i,enforceDirectoryTrailingSlash:s=!0}=n,o=l===r.ye.aws?["s3"]:l===r.ye.gcs?["gs","gcs"]:l===r.ye.azure?["azure","https"]:l===r.ye.aliyun?["oss"]:["https"],d=(0,r.Ez)(l,a?"multiple":"single",i);try{let e=new URL(t);if(!o.some(n=>e.protocol.includes(n)&&!t.replace(`${n}://`,"").startsWith("/")))throw Error();if(a){let n=t.endsWith("/"),l=e.pathname.replace(/^\/+/,"").split("/").filter(

1Boolean),a=l[l.length-1],o=i?r.lm[i]:void 0;if(!n&&a&&(o&&a.endsWith(o)||/.+\.[^/.]+$/.test(a))||s&&!n)return`Provide the URI of the folder that stores the target file, instead of the URI of the file. For example, ${d}`}if(!a&&t.endsWith("/"))return`Provide the URI of the file, instead of the URI of the folder. For example, ${d}`}catch(e){return`URI is invalid. Please provide a valid URI such as '${d}'`}}},614637:function(e,n,t){t.d(n,{Cn:()=>s,DD:()=>o,T5:()=>d,Z$:()=>c});let r={SINK_ENDPOINT_STATUS_CREATING:"Creating",SINK_ENDPOINT_STATUS_PENDING_ACCEPTANCE:"Pending Acceptance",SINK_ENDPOINT_STATUS_FAILED:"Failed",SINK_ENDPOINT_STATUS_UNSPECIFIED:"Unknown"},l=e=>{var n;if(!e||"SINK_ENDPOINT_STATUS_AVAILABLE"===e)return null;let t=null!==(n=r[e])&&void 0!==n?n:e;return`This private endpoint is ${t}. It becomes selectable when its status is Available.`},a=e=>{var n;return"AMAZON_MSK"===e.endpoint_type||(null===(n=e.advertised_listener)||void 0===n?void 0:n.root_domain_name)?null:"Kafka changefeeds require an advertised listener domain. Open the private endpoint and configure Advertised Listener for Kafka."},i=e=>[l(e.status),a(e)].filter(Boolean).join(" "),s=e=>{var n;return null!==(n=null==e?void 0:e.flatMap(e=>{var n;let t=null!==(n=e.id)&&void 0!==n?n:e.endpoint_id;if(!t)return[];let r=i(e);return{label:e.endpoint_name||t,value:t,disabled:!!r,disabledReason:r}}))&&void 0!==n?n:[]},o=(e,n)=>{let t=n.find(n=>n.value===e);return(null==t?void 0:t.disabledReason)||!0},d=(e,n)=>!!(null==e?void 0:e.some(e=>{var t;return(null!==(t=e.id)&&void 0!==t?t:e.endpoint_id)===n&&"AMAZON_MSK"===e.endpoint_type})),c=e=>({required:!e&&"Required"})},859224:function(e,n,t){t.d(n,{d:()=>r});let r={RUNNING:"RUNNING",SUCCEEDED:"SUCCEEDED",FAILED:"FAILED",CANCELED:"CANCELED",DELETED:"DELETED",EXPIRED:"EXPIRED"}},883452:function(e,n,t){t.d(n,{r:()=>r});let r={LOCAL:"LOCAL",S3:"S3",GCS:"GCS",AZURE_BLOB:"AZURE_BLOB",OSS:"OSS"}},875173:function(e,n,t){t.d(n,{P:()=>r});let r={CSV:"CSV",SQL:"SQL",AURORA_SNAPSHOT:"AURORA_SNAPSHOT",PARQUET:"PARQUET"}},980080:function(e,n,t){t.d(n,{s:()=>r});let r={ENUM_UNSPECIFIED:"ENUM_UNSPECIFIED",ENUM_S3:"ENUM_S3",ENUM_AZURE_BLOB:"ENUM_AZURE_BLOB",ENUM_OSS:"ENUM_OSS"}},252434:function(e,n,t){t.d(n,{I:()=>r});let r={BASE64:"BASE64",HEX:"HEX"}},361891:function(e,n,t){t.d(n,{q:()=>r});let r={S3_AUTH_TYPE_AK_SK:"S3_AUTH_TYPE_AK_SK",S3_AUTH_TYPE_ASSUME_ROLE:"S3_AUTH_TYPE_ASSUME_ROLE"}},813587:function(e,n,t){t.d(n,{L:()=>r});let r={ENUM_UNSPECIFIED:"ENUM_UNSPECIFIED",ENUM_PREPARING:"ENUM_PREPARING",ENUM_IMPORTING:"ENUM_IMPORTING",ENUM_COMPLETED:"ENUM_COMPLETED",ENUM_FAILED:"ENUM_FAILED",ENUM_CANCELING:"ENUM_CANCELING",ENUM_CANCELED:"ENUM_CANCELED",ENUM_SCALING_UP:"ENUM_SCALING_UP"}},309854:function(e,n,t){t.d(n,{Z:()=>s});var r=t(552676),l=t(965362),a=t(686128),i=t(245924);let s=({steps:e,className:n,current:t})=>{let[s,o]=(0,a.C)({value:t});return(0,r.jsx)(l.v,{styles:{root:{display:"flex",flexDirection:"row-reverse",gap:24,justifyContent:"center"},content:{paddingTop:0,maxWidth:880,flexGrow:1},stepBody:{marginTop:8}},iconSize:32,className:(0,i.W)(n),active:s,onStepClick:o,orientation:"vertical",children:e.map((e,n)=>{var t;let a=null!==(t=e.name)&&void 0!==t?t:`Step ${n+1}`;return(0,r.jsx)(l.v.Step,{label:a,description:e.description,allowStepClick:!1,allowStepSelect:!1,children:e.content},a)})})}},542420:function(e,n,t){t.d(n,{F:()=>o});var r=t(552676),l=t(128177),a=t(740521),i=t(98172),s=t(365582);let o=({option:e,checked:n})=>(0,r.jsxs)(l.Z,{wrap:"nowrap",justify:"space-between",sx:{flex:1},children:[(0,r.jsxs)(a.K,{gap:0,children:[(0,r.jsx)(i.Z,{variant:"title-md",fw:500,children:e.label}),(0,r.jsx)(i.Z,{variant:"body-lg",c:"carbon.7",children:e.description})]}),n&&(0,r.jsx)(s.NOm,{size:16,strokeWidth:3,style:{marginInlineStart:"auto"}})]})},398114:function(e,n,t){t.d(n,{f:()=>d});var r=t(552676),l=t(128177),a=t(740521),i=t(98172),s=t(105881),o=t(365582);let d=({option:e,checked:n})=>{let t=(0,r.jsxs)(l.Z,{wrap:"nowrap",justify:"space-between","data-testid":"changefeed-kafka-private-endpoint-option","data-endpoint-id":e.value,sx:{flex:1,minWidth:0,cursor:e.disabled?"not-allowed":void 0},children:[(0,r.jsxs)(a.K,{gap:0,sx:{minWidth:0},children:[(0,r.jsx)(i.Z,{variant:"title-md",fw:500,truncate:!0,children:e.label}),e.disabledReason&&(0,r.jsx)(i.Z,{variant:"body-lg",c:"carbon.7",children:"Unavailable"})]}),n&&(0,r.jsx)(o.NOm,{size:16,strokeWidth:3,style:{marginInlineStart:"auto"}})]});return e.disabledReason?(0,r.jsxs)(s.z,{withArrow:!0,position:"right",shadow:"md",withinPortal:!0,openDelay:200,children:[(0,r.jsx)(s.z.Target,{children:t}),(0,r.jsx)(s.z.Dropdown,{maw:320,children:(0,r.jsx)(i.Z,{variant:"body-lg",sx:{wordBreak:"break-word"},children:e.disabledReason})})]}):t}},785065:function(e,n,t){t.d(n,{u:()=>u});var r=t(552676),l=t(128177),a=t(105881),i=t(156102),s=t(740521),o=t(150288),d=t(365582),c=t(104493);function u({children:e,title:n,tooltip:t,isFetching:u,rightSection:p}){return(0,r.jsxs)(r.Fragment,{children:[(0,r.jsxs)(l.Z,{px:24,pt:24,pb:16,justify:"space-between",children:[(0,r.jsxs)(l.Z,{gap:8,children:[(0,r.jsx)(c.Z,{label:n}),t&&(0,r.jsxs)(a.z,{shadow:"md",withArrow:!0,children:[(0,r.jsx)(a.z.Target,{children:(0,r.jsx)(d.Us8,{size:16})}),(0,r.jsx)(a.z.Dropdown,{maw:400,children:t})]}),u&&(0,r.jsx)(i.a,{size:"xs"})]}),p]}),(0,r.jsx)(s.K,{px:24,pb:16,children:e}),(0,r.jsx)(o.i,{})]})}},769005:function(e,n,t){t.d(n,{r:()=>v});var r=t(552676),l=t(619102),a=t(128177),i=t(98172),s=t(105881),o=t(150288),d=t(190439),c=t(402899),u=t(366130),p=t(365582),h=t(275271),x=t(339941);

1let v=({defaultValue:e,onChange:n,validateError:t})=>{let[v,E]=(0,x.x)(e.length>0?e.map((e,n)=>({id:n,matcher:e.matcher,columns:e.columns})):[]);(0,h.useEffect)(()=>{null==n||n(v.map(e=>{var n,t;return{matcher:null===(n=e.matcher)||void 0===n?void 0:n.map(e=>e.trim()),columns:null===(t=e.columns)||void 0===t?void 0:t.map(e=>e.trim())}}))},[v,n]);let m=e=>{var n;return t?(null===(n=e.columns)||void 0===n?void 0:n.length)?e.columns.some(e=>!e)?"Invalid column selector":null:"Required":null};return(0,r.jsxs)(l.Z,{children:[(0,r.jsx)(l.Z.Section,{bg:"carbon.2",p:16,children:(0,r.jsxs)(a.Z,{gap:8,children:[(0,r.jsx)(i.Z,{c:"carbon.7",maw:250,flex:1,children:"Tables Matching"}),(0,r.jsx)(i.Z,{c:"carbon.7",flex:1,children:(0,r.jsxs)(a.Z,{gap:8,children:[(0,r.jsx)("span",{children:"Columns Selector"}),(0,r.jsxs)(s.z,{children:[(0,r.jsx)(s.z.Target,{children:(0,r.jsx)(p.Us8,{size:14})}),(0,r.jsx)(s.z.Dropdown,{maw:300,children:(0,r.jsxs)(i.Z,{children:["Selecting columns from events and sending only the data changes related to those columns to the downstream. Learn more details"," ",(0,r.jsx)("a",{href:"https://docs.pingcap.com/tidb/stable/ticdc-sink-to-kafka#column-selectors",target:"_blank",rel:"noreferrer",children:"here"}),"."]})})]})]})})]})}),(0,r.jsx)(o.i,{mx:-16}),v.map(e=>{var n,i,s;return(0,r.jsxs)(h.Fragment,{children:[(0,r.jsx)(l.Z.Section,{px:16,py:12,children:(0,r.jsxs)(a.Z,{gap:8,align:"flex-start",wrap:"nowrap",children:[(0,r.jsx)(d.o,{placeholder:"e.g. test.table1, test.table2",value:null===(n=e.matcher)||void 0===n?void 0:n.join(","),size:"sm",sx:{flex:1},maw:250,error:t&&!(null===(i=e.matcher)||void 0===i?void 0:i.length)&&"Required",onChange:n=>{E(t=>{let r=t.findIndex(n=>n.id===e.id);-1!==r&&(t[r].matcher=n.target.value.split(","))})}}),(0,r.jsxs)(a.Z,{flex:1,children:[(0,r.jsx)(d.o,{placeholder:"Use comma to separate multiple columns",size:"sm",value:null===(s=e.columns)||void 0===s?void 0:s.join(","),sx:{flexGrow:2},error:m(e),onChange:n=>{E(t=>{let r=t.findIndex(n=>n.id===e.id);-1!==r&&(t[r].columns=n.target.value.split(","))})}}),(0,r.jsx)(c.A,{variant:"default",onClick:()=>{E(n=>{let t=n.findIndex(n=>n.id===e.id);-1!==t&&n.splice(t,1)})},children:(0,r.jsx)(p.Q4p,{})})]})]})}),(0,r.jsx)(o.i,{mx:-16})]},e.id)}),(0,r.jsx)(l.Z.Section,{px:16,py:12,children:(0,r.jsx)(u.z,{leftSection:(0,r.jsx)(p.SC9,{}),variant:"default",size:"xs",onClick:()=>{E(e=>{e.push({id:Date.now(),matcher:[],columns:[]})})},children:"Add new selector"})})]})}},943326:function(e,n,t){t.d(n,{D:()=>b});var r=t(552676),l=t(619102),a=t(128177),i=t(98172),s=t(105881),o=t(150288),d=t(775364),c=t(461571),u=t(740521),p=t(701805),h=t(190439),x=t(402899),v=t(366130),E=t(566460),m=t(365582),g=t(78723),_=t(275271),f=t(339941),j=t(84320);let b=({defaultValue:e,onChange:n,validateError:t,simpleMode:b=!1})=>{let[S,N]=(0,f.x)(e.length>0?e.map((e,n)=>({id:n,...e,type:Object.keys(e).find(n=>{var t;return"matcher"!==n&&(Array.isArray(e[n])?e[n].length>0:(null===(t=e[n])||void 0===t?void 0:t.length)>0)})})):[]),A=(0,_.useMemo)(()=>S.map(e=>{var n;return{matcher:e.matcher,...e.type===j.KU.IGNORE_Event&&{ignore_event:(0,j.ce)(null!==(n=e.ignore_event)&&void 0!==n?n:[])},...e.type===j.KU.IGNORE_SQL&&{ignore_sql:e.ignore_sql},...e.type===j.KU.IGNORE_INSERT&&{ignore_insert_value_expr:e.ignore_insert_value_expr},...e.type===j.KU.IGNORE_UPDATE_NEW&&{ignore_update_new_value_expr:e.ignore_update_new_value_expr},...e.type===j.KU.IGNORE_UPDATE_OLD&&{ignore_update_old_value_expr:e.ignore_update_old_value_expr},...e.type===j.KU.IGNORE_DELETE&&{ignore_delete_value_expr:e.ignore_delete_value_expr}}}),[S]);return(0,_.useEffect)(()=>{null==n||n(A)},[A,n]),(0,r.jsxs)(l.Z,{children:[(0,r.jsx)(l.Z.Section,{bg:"carbon.2",p:16,children:(0,r.jsxs)(a.Z,{gap:8,children:[(0,r.jsx)(i.Z,{c:"carbon.7",maw:250,flex:1,children:"Tables Matching"}),(0,r.jsx)(i.Z,{c:"carbon.7",flex:1,children:(0,r.jsxs)(a.Z,{gap:8,children:[(0,r.jsx)("span",{children:"Filter Rule"}),(0,r.jsxs)(s.z,{children:[(0,r.jsx)(s.z.Target,{children:(0,r.jsx)(m.Us8,{size:14})}),(0,r.jsx)(s.z.Dropdown,{maw:300,children:(0,r.jsxs)(i.Z,{children:["You can configure event filter rules to filter out certain events. Learn more about the filter rules"," ",(0,r.jsx)("a",{href:"https://docs.pingcap.com/tidb/stable/ticdc-filter/#event-filter-rules",target:"_blank",rel:"noreferrer",children:"here"}),"."]})})]})]})})]})}),(0,r.jsx)(o.i,{mx:-16}),S.map((e,n)=>{var i,s,v,f;return(0,r.jsxs)(_.Fragment,{children:[(0,r.jsx)(l.Z.Section,{px:16,py:12,children:(0,r.jsxs)(a.Z,{gap:8,align:"flex-start",children:[(0,r.jsx)(d.x,{maw:250,flex:1,children:(0,r.jsx)(c.B,{size:"sm",placeholder:"e.g. 'test.*'. Press Enter to add",value:e.matcher,onCh

1ange:e=>{N(t=>{t[n].matcher=e})},error:t&&!(null===(i=e.matcher)||void 0===i?void 0:i.length)&&"Required"})}),(0,r.jsxs)(a.Z,{flex:1,align:"flex-start",wrap:"nowrap",children:[(0,r.jsxs)(u.K,{sx:{flexGrow:2},gap:8,children:[!b&&(0,r.jsx)(p.P,{size:"sm",value:e.type,data:Object.values(j.KU).map(e=>({label:(0,g.Z)(e.replaceAll("_"," ").replace("expr","expression")).replace("sql","SQL"),value:e})),onChange:e=>{N(t=>{t[n].type=e})}}),(0,r.jsxs)(a.Z,{gap:8,sx:{flexGrow:1},wrap:"nowrap",children:[!b&&(0,r.jsx)(m.f7m,{size:16,c:"carbon.6"}),e.type===j.KU.IGNORE_Event&&(0,r.jsx)(E.Q,{value:e.ignore_event,size:"sm",data:j.xl.map(n=>{var t,r;return{label:n,value:n,disabled:(null===(t=e.ignore_event)||void 0===t?void 0:t.includes("all dml"))&&j.Wu.includes(n)||(null===(r=e.ignore_event)||void 0===r?void 0:r.includes("all ddl"))&&j.fb.includes(n)}}),onChange:e=>{N(t=>{t[n].ignore_event=e})},clearable:!0,maxDropdownHeight:400,sx:{flexGrow:2},placeholder:"Select ignored events",error:t&&!(null===(s=e.ignore_event)||void 0===s?void 0:s.length)&&"Required"}),!b&&e.type===j.KU.IGNORE_SQL&&(0,r.jsx)(c.B,{value:e.ignore_sql,size:"sm",onChange:e=>{N(t=>{t[n].ignore_sql=e})},placeholder:"e.g. `^drop`. Press Enter to add.",error:t&&!(null===(v=e.ignore_sql)||void 0===v?void 0:v.length)&&"Required",sx:{flexGrow:2}}),!b&&[j.KU.IGNORE_INSERT,j.KU.IGNORE_UPDATE_NEW,j.KU.IGNORE_UPDATE_OLD,j.KU.IGNORE_DELETE].includes(e.type)&&(0,r.jsx)(h.o,{size:"sm",value:e[e.type],onChange:t=>{N(r=>{r[n][e.type]=t.target.value})},placeholder:"e.g. `id = 1`",sx:{flexGrow:2},error:t&&!(null===(f=e[e.type])||void 0===f?void 0:f.length)&&"Required"})]})]}),(0,r.jsx)(x.A,{variant:"default",size:32,onClick:()=>{N(e=>{e.splice(n,1)})},children:(0,r.jsx)(m.Q4p,{size:14})})]})]})}),(0,r.jsx)(o.i,{mx:-16})]},e.id)}),(0,r.jsx)(l.Z.Section,{px:16,py:12,children:(0,r.jsx)(v.z,{leftSection:(0,r.jsx)(m.SC9,{}),variant:"default",size:"xs",onClick:()=>{N(e=>{e.push({id:Date.now(),matcher:[],type:j.KU.IGNORE_Event})})},children:"Add new filter"})})]})}},498638:function(e,n,t){t.d(n,{B:()=>d});var r=t(552676),l=t(740521),a=t(98172),i=t(98455),s=t(90206),o=t(199417);let d=({name:e})=>(0,r.jsxs)(l.K,{gap:8,children:[(0,r.jsx)(a.Z,{variant:"label-lg",children:"Output Raw Change Event"}),(0,r.jsx)(i.j,{name:e,onChange:e=>{(0,s.fn)(o.P.DedicatedChangefeed.Enable.ButtonClicked,{field:"output_raw_change_event",value:e.target.checked})},label:(0,r.jsxs)("div",{children:["Output raw change events without splitting UPDATE events. Learn more about"," ",(0,r.jsx)("a",{href:"https://docs.pingcap.com/tidb/v8.1/ticdc-split-update-behavior/",target:"_blank",rel:"noopener noreferrer","data-mp-event":"Event Splitting Link Clicked",children:"TiCDC Behavior in Splitting UPDATE Events"}),"."]})})]})},81296:function(e,n,t){t.d(n,{l:()=>j});var r=t(552676),l=t(696387),a=t(619102),i=t(128177),s=t(98172),o=t(740521),d=t(775364),c=t(190439),u=t(402899),p=t(915030),h=t(366130),x=t(490764),v=t(825539),E=t(365582),m=t(275271),g=t(469987),_=t(88777),f=t(14978);function j({name:e,target:n}){let{control:t,watch:j}=(0,g.Gc)(),b=j(e),[S,N]=(0,m.useState)(()=>1===b.length?"single":"multiple"),{fields:A,append:U,remove:C}=(0,g.Dq)({control:t,name:e});return(0,r.jsxs)(r.Fragment,{children:[(0,r.jsx)(l.s,{data:[{label:"A single partition dispatcher for all tables",value:"single"},{label:"Different partition dispatchers for different tables",value:"multiple"}],value:S,onChange:e=>N(e)}),(0,r.jsxs)(a.Z,{children:[(0,r.jsx)(a.Z.Section,{children:(0,r.jsxs)(i.Z,{p:16,bg:"carbon.3",wrap:"nowrap",children:[(0,r.jsx)(s.Z,{variant:"body-lg",c:"carbon.7",w:200,children:"Tables Matching"}),(0,r.jsxs)(s.Z,{variant:"body-lg",c:"carbon.7",children:["Distribute change events to ",n," partitions using the following rule"]})]})}),(0,r.jsx)(a.Z.Section,{children:(0,r.jsx)(o.K,{p:16,gap:16,children:A.map((n,t)=>(0,r.jsxs)(d.x,{sx:e=>({"&:not(:last-child)":{borderBottom:`1px solid ${e.colors.carbon[3]}`,paddingBottom:16}}),children:[(0,r.jsxs)(i.Z,{wrap:"nowrap",children:[(0,r.jsx)(g.Qr,{name:`${e}.${t}.matcher`,render:({field:e})=>(0,r.jsx)(c.o,{...e,value:e.value.join(","),onChange:n=>e.onChange(n.target.value.split(",")),size:"sm",placeholder:"Enter tables matching",w:200})}),(0,r.jsx)(x.i,{name:`${e}.${t}.partition_type`,data:_.rd.map(e=>({value:e.value,label:e.text})),placeholder:"Select partition dispatcher",size:"sm",sx:{flex:1}}),"multiple"===S&&(0,r.jsx)(u.A,{variant:"default",size:32,onClick:()=>C(t),sx:b.length<=1?{visibility:"hidden"}:void 0,children:(0,r.jsx)(E.Q4p,{})})]}),b[t].partition_type===f.W.COLUMNS&&(0,r.jsxs)(p.k,{gap:16,mt:8,children:[(0,r.jsxs)(p.k,{align:"center",justify:"flex-end",gap:8,w:200,children:[(0,r.jsx)(d.x,{component:E.f7m,size:24,c:"carbon.5",mr:8}),(0,r.jsx)(s.Z,{variant:"label-md",c:"carbon.7",span:!0,children:"Column Values"})]}),(0,r.jsx)(g.Qr,{name:`${e}.${t}.columns`,render:({field:e})=>{var n,t;return(0,r.jsx)(c.o,{...e,placeholder:"Enter column values, separated by commas",size:"sm",sx:{flex:1},value:null!==(t=null===(n=e.value)||void 0===n?void 0:n.join(","))&&void 0!==t?t:"",onChange:n=>e.onChange(n.target.value.split(","))})}}),(0,r.jsx)(u.A,{sx:{visibility:"hidden"},size:32,children:(0,r.jsx)(E.Q4p,{})})]}),b[t].partition_type===f.W.INDEX_VALUE&&(0,r.jsxs)(p.k,{gap:16,mt:8,children:[(0,r.jsxs)(p.k,{align:"center",justify:"flex-end",gap:8,w:200,children:[(0,r.jsx)(d.x,{component:E.f7m,size:24,c:"carbon.5",mr:8}),(0,r.jsx)(s.Z,{variant:"label-md",c:"carbon.7",span:!0,children:"Index Name"})]}),(0,r.jsx)(v.c,{name:`${e}.${t}.index_name`,placeholder:"Enter index name, this is optional",size:"sm",sx:{flex:1}}),(0,r.jsx)(u.A,{sx:{visibility:"hidden"},size:32,children:(0,r.jsx)(E.Q4p,{})})]})]},n.id))})}),"multiple"===S&&(0,r.jsx)("div",{children:(0,r.jsx)(h.z,{variant:"default",size:"sm",leftSection:(0,r.jsx)(E.SC9,{strokeWidth:3}),onClick:()=>U({matcher:["*.*"],partition_type:f.W.INDEX_VALUE}),children:"Add New"})})]})]})}},382137:function(e,n,t){t.d(n,{f:()=>d});var r=t(552676),l=t(128177),a=t(98172),i=t(825539),s=t(469987),o=t(308026);function d({name:e}){let{watch:n}=(0,s.Gc)(),t=n(`${e}.dispatch_type`),d=t===o.u.DISPATCH_TYPE_BY_TABLE,c=t===o.u.DISPATCH_TYPE_BY_DATABASE,u=n(`${e}.topic_prefix`),p=n(`${e}.separator`),h=n(`${e}.topic_suffix`);return(0,r.jsxs)(r.Fragment,{children:[(0,r.jsxs)(l.Z,{justify:"space-between",children:[(0,r.jsx)(i.c,{label:"Topic Prefix",name:`${e}.topic_prefix`,placeholder:"Enter prefix",sx:{flex:1}}),d&&(0,r.jsx)(i.c,{label:"Separator",name:`${e}.separator`,placeholder:"Enter separator",sx:{flex:1}}),(0,r.jsx)(i.c,{label:"Topic Suffix",name:`${e}.topic_suffix`,placeholder:"Enter separator",sx:{flex:1}})]}),(0,r.jsxs)(a.Z,{c:"carbon.7",variant:"body-lg",children:["For example, a table in `db1` named `tbl2` will have its row change events sent to topic:",(0,r.jsx)(a.Z,{span:!0,ml:4,fw:500,children:[u,...c?["db1"]:["db1",p,"tbl2"],h].filter(

1Boolean).map((e,n)=>n%2==0?(0,r.jsx)(a.Z,{span:!0,c:"cyan.6",children:e}):(0,r.jsx)("span",{children:e}))})]})]})}},174390:function(e,n,t){t.d(n,{S:()=>u});var r=t(552676),l=t(560162),a=t(128177),i=t(105881),s=t(825539),o=t(365582),d=t(469987),c=t(308026);function u({name:e,tooltip:n}){let{watch:t}=(0,d.Gc)(),u=t(`${e}.dispatch_type`)===c.u.DISPATCH_TYPE_ONE_TOPIC;return(0,r.jsx)(s.c,{label:(0,r.jsx)(l.I.Label,{mb:0,children:(0,r.jsxs)(a.Z,{gap:8,children:[(0,r.jsx)("span",{children:u?"Topic Name":"Default Topic Name"}),!u&&(0,r.jsxs)(i.z,{children:[(0,r.jsx)(i.z.Target,{children:(0,r.jsx)(o.Us8,{size:14})}),(0,r.jsx)(i.z.Dropdown,{maw:400,children:n})]})]})}),name:`${e}.default_topic`,rules:{required:!!u&&"Required"},placeholder:u?"Enter the topic name":"Enter the default topic name"})}},104493:function(e,n,t){t.d(n,{Z:()=>a});var r=t(552676),l=t(98172);let a=({className:e,label:n,description:t})=>(0,r.jsxs)("div",{className:e,children:[(0,r.jsx)(l.Z,{variant:"title-lg",children:n}),t&&(0,r.jsx)(l.Z,{variant:"body-lg",c:"carbon.7",mt:4,children:t})]})}}]);