feat: Kafka admin client

Cargo.toml

@@ -1,5 +1,5 @@
 [workspace]
-members = ["rust/operator-binary", "rust/agent-binary", "rust/shared"]
+members = ["rust/operator-binary", "rust/agent-binary", "rust/kafka-admin", "rust/shared"]
 resolver = "2"
 
 [workspace.package]
@@ -14,18 +14,24 @@ stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git",
 stackable-kafka-shared = { path = "rust/shared" }
 
 anyhow = "1.0"
+base64 = "0.22"
 built = { version = "0.8", features = ["chrono", "git2"] }
+bytes = "1.12"
 clap = "4.6"
 const_format = "0.2"
 futures = "0.3"
 indoc = "2.0"
+kafka-protocol = { version = "0.18", default-features = false, features = ["broker", "client"] }
 rstest = "0.26"
+rustls = { version = "0.23", default-features = false, features = ["logging", "ring", "std", "tls12"] }
 semver = "1.0"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 snafu = "0.9"
 strum = { version = "0.28", features = ["derive"] }
 tokio = { version = "1.53", features = ["full"] }
+tokio-rustls = { version = "0.26", default-features = false, features = ["logging", "ring", "tls12"] }
+tokio-util = { version = "0.7", features = ["codec"] }
 tracing = "0.1"
 
 [patch."https://github.com/stackabletech/operator-rs.git"]

rust/kafka-admin/Cargo.toml

@@ -0,0 +1,25 @@
+[package]
+name = "stackable-kafka-admin"
+description = "Kafka admin client of the Stackable agent for Apache Kafka"
+version.workspace = true
+authors.workspace = true
+license.workspace = true
+edition.workspace = true
+repository.workspace = true
+publish = false
+
+[dependencies]
+anyhow.workspace = true
+base64.workspace = true
+bytes.workspace = true
+futures.workspace = true
+kafka-protocol.workspace = true
+rustls.workspace = true
+snafu.workspace = true
+tokio.workspace = true
+tokio-rustls.workspace = true
+tokio-util.workspace = true
+
+[dev-dependencies]
+rstest.workspace = true
+tokio = { workspace = true, features = ["test-util"] }