Skip to content

Commit d56f8c6

Browse files
shiyuhang0shiyuhang0
authored
Merge branch 'main' into plc_cli
2 parents 7ad88c1 + eb39fa9 commit d56f8c6

15 files changed

Lines changed: 425 additions & 154 deletions

File tree

‎Makefile‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,6 @@ generate-v1beta1-serverless-client: install-openapi-generator ## Generate server
5353
@echo "==> Generating serverless audit log client"
5454
rm -rf pkg/tidbcloud/v1beta1/serverless/auditlog
5555
cd tools/openapi-generator && npx openapi-generator-cli generate --inline-schema-options RESOLVE_INLINE_ENUMS=true --additional-properties=withGoMod=false,enumClassPrefix=true,disallowAdditionalPropertiesIfNotPresent=false --global-property=apiTests=false,apiDocs=false,modelDocs=false,modelTests=false -i ../../pkg/tidbcloud/v1beta1/serverless/auditlog.swagger.json -g go -o ../../pkg/tidbcloud/v1beta1/serverless/auditlog --package-name auditlog -c go/config.yaml
56-
cd pkg && go fmt ./tidbcloud/v1beta1/serverless/... && goimports -w .
5756
@echo "==> Generating serverless cdc client"
5857
rm -rf pkg/tidbcloud/v1beta1/serverless/cdc
5958
cd tools/openapi-generator && npx openapi-generator-cli generate --inline-schema-options RESOLVE_INLINE_ENUMS=true --additional-properties=withGoMod=false,enumClassPrefix=true,disallowAdditionalPropertiesIfNotPresent=false --global-property=apiTests=false,apiDocs=false,modelDocs=false,modelTests=false -i ../../pkg/tidbcloud/v1beta1/serverless/cdc.swagger.json -g go -o ../../pkg/tidbcloud/v1beta1/serverless/cdc --package-name cdc -c go/config.yaml

‎go.mod‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
module github.com/tidbcloud/tidbcloud-cli
22

3-
go 1.24
3+
go 1.24.0
44

55
require (
66
github.com/AlecAivazis/survey/v2 v2.3.6
@@ -37,7 +37,7 @@ require (
3737
go.einride.tech/aip v0.67.1
3838
go.uber.org/zap v1.27.0
3939
golang.org/x/oauth2 v0.27.0
40-
golang.org/x/sys v0.35.0
40+
golang.org/x/sys v0.38.0
4141
gopkg.in/yaml.v3 v3.0.1
4242
)
4343

@@ -109,13 +109,13 @@ require (
109109
github.com/yuin/goldmark v1.6.0 // indirect
110110
github.com/yuin/goldmark-emoji v1.0.2 // indirect
111111
go.uber.org/multierr v1.11.0 // indirect
112-
golang.org/x/crypto v0.41.0 // indirect
112+
golang.org/x/crypto v0.45.0 // indirect
113113
golang.org/x/exp v0.0.0-20240604190554-fc45aab8b7f8 // indirect
114-
golang.org/x/net v0.43.0 // indirect
115-
golang.org/x/sync v0.16.0 // indirect
116-
golang.org/x/term v0.34.0 // indirect
117-
golang.org/x/text v0.28.0 // indirect
118-
golang.org/x/tools v0.36.0 // indirect
114+
golang.org/x/net v0.47.0 // indirect
115+
golang.org/x/sync v0.18.0 // indirect
116+
golang.org/x/telemetry v0.0.0-20251008203120-078029d740a8 // indirect
117+
golang.org/x/term v0.37.0 // indirect
118+
golang.org/x/text v0.31.0 // indirect
119119
google.golang.org/protobuf v1.34.1 // indirect
120120
gopkg.in/ini.v1 v1.67.0 // indirect
121121
gopkg.in/natefinch/lumberjack.v2 v2.0.0 // indirect

‎go.sum‎

Lines changed: 18 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -723,15 +723,15 @@ go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
723723
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
724724
golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
725725
golang.org/x/crypto v0.14.0/go.mod h1:MVFd36DqK4CsrnJYDkBA3VC4m2GkXAM0PvzMCn4JQf4=
726-
golang.org/x/crypto v0.41.0 h1:WKYxWedPGCTVVl5+WHSSrOBT0O8lx32+zxmHxijgXp4=
727-
golang.org/x/crypto v0.41.0/go.mod h1:pO5AFd7FA68rFak7rOAGVuygIISepHftHnr8dr6+sUc=
726+
golang.org/x/crypto v0.45.0 h1:jMBrvKuj23MTlT0bQEOBcAE0mjg8mK9RXFhRH6nyF3Q=
727+
golang.org/x/crypto v0.45.0/go.mod h1:XTGrrkGJve7CYK7J8PEww4aY7gM3qMCElcJQ8n8JdX4=
728728
golang.org/x/exp v0.0.0-20240604190554-fc45aab8b7f8 h1:LoYXNGAShUG3m/ehNk4iFctuhGX/+R1ZpfJ4/ia80JM=
729729
golang.org/x/exp v0.0.0-20240604190554-fc45aab8b7f8/go.mod h1:jj3sYF3dwk5D+ghuXyeI3r5MFf+NT2An6/9dOA95KSI=
730730
golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
731731
golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4=
732732
golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
733-
golang.org/x/mod v0.27.0 h1:kb+q2PyFnEADO2IEF935ehFUXlWiNjJWtRNgBLSfbxQ=
734-
golang.org/x/mod v0.27.0/go.mod h1:rWI627Fq0DEoudcK+MBkNkCe0EetEaDSwJJkCcjpazc=
733+
golang.org/x/mod v0.29.0 h1:HV8lRxZC4l2cr3Zq1LvtOsi/ThTgWnUk/y64QSs8GwA=
734+
golang.org/x/mod v0.29.0/go.mod h1:NyhrlYXJ2H4eJiRy/WDBO6HMqZQ6q9nk4JzS3NuCK+w=
735735
golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
736736
golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
737737
golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
@@ -740,15 +740,15 @@ golang.org/x/net v0.0.0-20221002022538-bcab6841153b/go.mod h1:YDH+HFinaLZZlnHAfS
740740
golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
741741
golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg=
742742
golang.org/x/net v0.17.0/go.mod h1:NxSsAGuq816PNPmqtQdLE42eU2Fs7NoRIZrHJAlaCOE=
743-
golang.org/x/net v0.43.0 h1:lat02VYK2j4aLzMzecihNvTlJNQUq316m2Mr9rnM6YE=
744-
golang.org/x/net v0.43.0/go.mod h1:vhO1fvI4dGsIjh73sWfUVjj3N7CA9WkKJNQm2svM6Jg=
743+
golang.org/x/net v0.47.0 h1:Mx+4dIFzqraBXUugkia1OOvlD6LemFo1ALMHjrXDOhY=
744+
golang.org/x/net v0.47.0/go.mod h1:/jNxtkgq5yWUGYkaZGqo27cfGZ1c5Nen03aYrrKpVRU=
745745
golang.org/x/oauth2 v0.27.0 h1:da9Vo7/tDv5RH/7nZDz1eMGS/q1Vv1N/7FCrBhI9I3M=
746746
golang.org/x/oauth2 v0.27.0/go.mod h1:onh5ek6nERTohokkhCD/y2cV4Do3fxFHFuAejCkRWT8=
747747
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
748748
golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
749749
golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
750-
golang.org/x/sync v0.16.0 h1:ycBJEhp9p4vXvUZNszeOq0kGTPghopOL8q0fq3vstxw=
751-
golang.org/x/sync v0.16.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
750+
golang.org/x/sync v0.18.0 h1:kr88TuHDroi+UVf+0hZnirlk8o8T+4MrK6mr60WkH/I=
751+
golang.org/x/sync v0.18.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI=
752752
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
753753
golang.org/x/sys v0.0.0-20190222072716-a9d3bda3a223/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
754754
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -763,24 +763,26 @@ golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
763763
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
764764
golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
765765
golang.org/x/sys v0.13.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
766-
golang.org/x/sys v0.35.0 h1:vz1N37gP5bs89s7He8XuIYXpyY0+QlsKmzipCbUtyxI=
767-
golang.org/x/sys v0.35.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
766+
golang.org/x/sys v0.38.0 h1:3yZWxaJjBmCWXqhN1qh02AkOnCQ1poK6oF+a7xWL6Gc=
767+
golang.org/x/sys v0.38.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
768+
golang.org/x/telemetry v0.0.0-20251008203120-078029d740a8 h1:LvzTn0GQhWuvKH/kVRS3R3bVAsdQWI7hvfLHGgh9+lU=
769+
golang.org/x/telemetry v0.0.0-20251008203120-078029d740a8/go.mod h1:Pi4ztBfryZoJEkyFTI5/Ocsu2jXyDr6iSdgJiYE/uwE=
768770
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
769771
golang.org/x/term v0.0.0-20210503060354-a79de5458b56/go.mod h1:tfny5GFUkzUvx4ps4ajbZsCe5lw1metzhBm9T3x7oIY=
770772
golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
771773
golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
772774
golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo=
773775
golang.org/x/term v0.13.0/go.mod h1:LTmsnFJwVN6bCy1rVCoS+qHT1HhALEFxKncY3WNNh4U=
774-
golang.org/x/term v0.34.0 h1:O/2T7POpk0ZZ7MAzMeWFSg6S5IpWd/RXDlM9hgM3DR4=
775-
golang.org/x/term v0.34.0/go.mod h1:5jC53AEywhIVebHgPVeg0mj8OD3VO9OzclacVrqpaAw=
776+
golang.org/x/term v0.37.0 h1:8EGAD0qCmHYZg6J17DvsMy9/wJ7/D/4pV/wfnld5lTU=
777+
golang.org/x/term v0.37.0/go.mod h1:5pB4lxRNYYVZuTLmy8oR2BH8dflOR+IbTYFD8fi3254=
776778
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
777779
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
778780
golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
779781
golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
780782
golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8=
781783
golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
782-
golang.org/x/text v0.28.0 h1:rhazDwis8INMIwQ4tpjLDzUhx6RlXqZNPEM0huQojng=
783-
golang.org/x/text v0.28.0/go.mod h1:U8nCwOR8jO/marOQ0QbDiOngZVEBB7MAiitBuMjXiNU=
784+
golang.org/x/text v0.31.0 h1:aC8ghyu4JhP8VojJ2lEHBnochRno1sgL6nEi9WGFGMM=
785+
golang.org/x/text v0.31.0/go.mod h1:tKRAlv61yKIjGGHX/4tP1LTbc13YSec1pxVEWXzfoeM=
784786
golang.org/x/time v0.3.0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
785787
golang.org/x/time v0.5.0 h1:o7cqy6amK/52YcAKIPlM3a+Fpj35zvRj2TP+e1xFSfk=
786788
golang.org/x/time v0.5.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM=
@@ -791,8 +793,8 @@ golang.org/x/tools v0.0.0-20191108193012-7d206e10da11/go.mod h1:b+2E5dAYhXwXZwtn
791793
golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
792794
golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
793795
golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU=
794-
golang.org/x/tools v0.36.0 h1:kWS0uv/zsvHEle1LbV5LE8QujrxB3wfQyxHfhOk0Qkg=
795-
golang.org/x/tools v0.36.0/go.mod h1:WBDiHKJK8YgLHlcQPYQzNCkUxUypCaa5ZegCVutKm+s=
796+
golang.org/x/tools v0.38.0 h1:Hx2Xv8hISq8Lm16jvBZ2VQf+RLmbd7wVUsALibYI/IQ=
797+
golang.org/x/tools v0.38.0/go.mod h1:yEsQ/d/YK8cjh0L6rZlY8tgtlKiBNTL14pGDJPJpYQs=
796798
golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
797799
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
798800
golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028 h1:+cNy6SZtPcJQH3LJVLOSmiC7MMxXNOb3PU/VUEz+EhU=

‎install.sh‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515

16-
version="1.0.0-beta.7"
16+
version="1.0.0-beta.8"
1717

1818
repo='https://github.com/tidbcloud/tidbcloud-cli/releases/download'
1919
if [ -n "$TICLOUD_MIRRORS" ]; then

‎internal/cli/serverless/changefeed/template.go‎

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,10 +48,15 @@ const (
4848
"enableTls": false
4949
},
5050
"dataFormat": {
51-
// "protocol": "CANAL_JSON", "AVRO", "OPEN_PROTOCOL"
51+
// "protocol": "CANAL_JSON", "AVRO", "OPEN_PROTOCOL", "DEBEZIUM"
5252
"protocol": "CANAL_JSON",
5353
// available when protocol is CANAL_JSON
5454
"enableTidbExtension": false,
55+
// available when protocol is DEBEZIUM
56+
"debeziumConfig": {
57+
"disableOutputOldValue": false,
58+
"disableSchema": false
59+
},
5560
// available when protocol is AVRO
5661
"avroConfig": {
5762
"decimalHandlingMode": "PRECISE",
@@ -122,6 +127,10 @@ const (
122127
"dataFormat": {
123128
"protocol": "CANAL_JSON",
124129
"enableTidbExtension": false,
130+
"debeziumConfig": {
131+
"disableOutputOldValue": false,
132+
"disableSchema": false
133+
},
125134
"avroConfig": {
126135
"decimalHandlingMode": "PRECISE",
127136
"bigintUnsignedHandlingMode": "LONG",

‎latest-version‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
v1.0.0-beta.7
1+
v1.0.0-beta.8

‎pkg/tidbcloud/v1beta1/serverless/cdc.swagger.json‎

Lines changed: 19 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -916,6 +916,19 @@
916916
"endpoint"
917917
]
918918
},
919+
"DebeziumConfig": {
920+
"type": "object",
921+
"properties": {
922+
"disableOutputOldValue": {
923+
"type": "boolean",
924+
"title": "whether disable output old value, default to false"
925+
},
926+
"disableSchema": {
927+
"type": "boolean",
928+
"title": "disable schema in debezium message, default to false"
929+
}
930+
}
931+
},
919932
"DecimalHandlingMode.Enum": {
920933
"type": "string",
921934
"enum": [
@@ -1083,6 +1096,9 @@
10831096
},
10841097
"avroConfig": {
10851098
"$ref": "#/definitions/AvroConfig"
1099+
},
1100+
"debeziumConfig": {
1101+
"$ref": "#/definitions/DebeziumConfig"
10861102
}
10871103
}
10881104
},
@@ -1215,9 +1231,10 @@
12151231
"enum": [
12161232
"CANAL_JSON",
12171233
"OPEN_PROTOCOL",
1218-
"AVRO"
1234+
"AVRO",
1235+
"DEBEZIUM"
12191236
],
1220-
"description": " - CANAL_JSON: Canal-JSON protocol.\n - OPEN_PROTOCOL: Open Protocol.\n - AVRO: Avro protocol."
1237+
"description": " - CANAL_JSON: Canal-JSON protocol.\n - OPEN_PROTOCOL: Open Protocol.\n - AVRO: Avro protocol.\n - DEBEZIUM: Debezium protocol."
12211238
},
12221239
"KafkaType.Enum": {
12231240
"type": "string",

‎pkg/tidbcloud/v1beta1/serverless/cdc/.openapi-generator/FILES‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@ model_changefeed_type_enum.go
2323
model_changefeeds.go
2424
model_checkpoint.go
2525
model_confluent_schema_registry.go
26+
model_debezium_config.go
2627
model_decimal_handling_mode_enum.go
2728
model_describe_schema_table_resp.go
2829
model_event_filter_rule.go

‎pkg/tidbcloud/v1beta1/serverless/cdc/README.md‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,6 +110,7 @@ Class | Method | HTTP request | Description
110110
- [Changefeeds](docs/Changefeeds.md)
111111
- [Checkpoint](docs/Checkpoint.md)
112112
- [ConfluentSchemaRegistry](docs/ConfluentSchemaRegistry.md)
113+
- [DebeziumConfig](docs/DebeziumConfig.md)
113114
- [DecimalHandlingModeEnum](docs/DecimalHandlingModeEnum.md)
114115
- [DescribeSchemaTableResp](docs/DescribeSchemaTableResp.md)
115116
- [EventFilterRule](docs/EventFilterRule.md)

‎pkg/tidbcloud/v1beta1/serverless/cdc/api/openapi.yaml‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -745,6 +745,15 @@ components:
745745
required:
746746
- endpoint
747747
type: object
748+
DebeziumConfig:
749+
properties:
750+
disableOutputOldValue:
751+
title: "whether disable output old value, default to false"
752+
type: boolean
753+
disableSchema:
754+
title: "disable schema in debezium message, default to false"
755+
type: boolean
756+
type: object
748757
DecimalHandlingMode.Enum:
749758
description: |2-
750759
- PRECISE: Precise handling mode for decimals.
@@ -872,6 +881,8 @@ components:
872881
type: boolean
873882
avroConfig:
874883
$ref: '#/components/schemas/AvroConfig'
884+
debeziumConfig:
885+
$ref: '#/components/schemas/DebeziumConfig'
875886
type: object
876887
Kafka.Network:
877888
properties:
@@ -969,10 +980,12 @@ components:
969980
- CANAL_JSON: Canal-JSON protocol.
970981
- OPEN_PROTOCOL: Open Protocol.
971982
- AVRO: Avro protocol.
983+
- DEBEZIUM: Debezium protocol.
972984
enum:
973985
- CANAL_JSON
974986
- OPEN_PROTOCOL
975987
- AVRO
988+
- DEBEZIUM
976989
type: string
977990
KafkaType.Enum:
978991
description: |2-

0 commit comments

Comments
 (0)