Skip to content

Commit 2368e4a

Browse files
committed
feat(databricks zerobus): add new databricks_zerobus for ingesting data into Databricks
1 parent 478d7c4 commit 2368e4a

29 files changed

Lines changed: 5107 additions & 25 deletions

Cargo.lock

Lines changed: 211 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -331,6 +331,9 @@ prost = { workspace = true, optional = true }
331331
prost-reflect = { workspace = true, optional = true }
332332
prost-types = { workspace = true, optional = true }
333333

334+
# Databricks Zerobus
335+
databricks-zerobus-ingest-sdk = { git = "https://github.com/databricks/zerobus-sdk-rs", rev = "326f97e7048fc411165b8ffba7cfef460b04c86a", optional = true }
336+
334337
# GCP
335338
goauth = { version = "0.16.0", optional = true }
336339
smpl_jwt = { version = "0.8.0", default-features = false, optional = true }
@@ -602,7 +605,7 @@ enrichment-tables-mmdb = ["dep:maxminddb"]
602605
enrichment-tables-memory = ["dep:evmap", "dep:evmap-derive", "dep:thread_local"]
603606

604607
# Codecs
605-
codecs-arrow = ["dep:arrow", "dep:arrow-schema", "vector-lib/arrow"]
608+
codecs-arrow = ["dep:arrow", "dep:arrow-schema", "vector-lib/arrow", "databricks-zerobus-ingest-sdk?/arrow-flight"]
606609
codecs-opentelemetry = ["vector-lib/opentelemetry"]
607610
codecs-syslog = ["vector-lib/syslog"]
608611

@@ -808,6 +811,7 @@ sinks-logs = [
808811
"sinks-clickhouse",
809812
"sinks-console",
810813
"sinks-databend",
814+
"sinks-databricks-zerobus",
811815
"sinks-datadog_events",
812816
"sinks-datadog_logs",
813817
"sinks-datadog_traces",
@@ -876,6 +880,7 @@ sinks-chronicle = []
876880
sinks-clickhouse = ["dep:nom", "dep:rust_decimal", "codecs-arrow"]
877881
sinks-console = []
878882
sinks-databend = ["dep:databend-client"]
883+
sinks-databricks-zerobus = ["dep:databricks-zerobus-ingest-sdk", "dep:prost-reflect", "dep:base64"]
879884
sinks-datadog_events = []
880885
sinks-datadog_logs = []
881886
sinks-datadog_metrics = ["protobuf-build", "dep:prost", "dep:prost-reflect"]
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Add a new `databricks_zerobus` sink that streams log data to Databricks Unity Catalog tables via the Zerobus ingestion service. Supports OAuth 2.0 authentication, automatic schema fetching from Unity Catalog, and protobuf batch encoding.

0 commit comments

Comments
 (0)