feat(source): support private link for kafka connector (risingwavelab…

…s#8247) Signed-off-by: Runji Wang <[email protected]> Co-authored-by: Runji Wang <[email protected]>
Little-Wallace · Mar 17, 2023 · 4f430ac · 4f430ac
1 parent 7b5ffb4
commit 4f430ac
Show file tree

Hide file tree

Showing 33 changed files with 1,273 additions and 35 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -58,6 +58,7 @@ repository = "https://github.com/risingwavelabs/risingwave"
 aws-config = { version = "0.51", default-features = false, features = ["rt-tokio", "native-tls"] }
 aws-sdk-kinesis = { version = "0.21", default-features = false, features = ["rt-tokio", "native-tls"] }
 aws-sdk-s3 = { version = "0.21", default-features = false, features = ["rt-tokio","native-tls"] }
+aws-sdk-ec2 = { version = "0.21", default-features = false, features = ["rt-tokio","native-tls"] }
 aws-sdk-sqs = { version = "0.21", default-features = false, features = ["rt-tokio", "native-tls"] }
 aws-smithy-http = "0.51"
 aws-smithy-types = "0.51"
@@ -122,3 +123,4 @@ tokio-stream = { git = "https://github.com/madsim-rs/tokio.git", rev = "0c25710"
 tokio-retry = { git = "https://github.com/madsim-rs/rust-tokio-retry.git", rev = "95e2fd3" }
 tokio-postgres = { git = "https://github.com/madsim-rs/rust-postgres.git", rev = "87ca1dc" }
 postgres-types = { git = "https://github.com/madsim-rs/rust-postgres.git", rev = "87ca1dc" }
+madsim-rdkafka = { git = "https://github.com/madsim-rs/madsim.git", rev = "43e025d" }
diff --git a/dashboard/proto/gen/catalog.ts b/dashboard/proto/gen/catalog.ts