databricks-zerobus-ingest

Generate Protobuf schemas and stream records into Unity Catalog managed Delta tables via gRPC.

Updated May 20, 2026
One-click install
npx skills add https://github.com/ice-droid-99/BI-Dashboard-Generation-Agent-in-Databricks- --skill databricks-zerobus-ingest-ice-droid-99
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: databricks-zerobus-ingest
Source: https://github.com/ice-droid-99/BI-Dashboard-Generation-Agent-in-Databricks-/tree/main/.gemini/skills/databricks-zerobus-ingest
Command: npx skills add https://github.com/ice-droid-99/BI-Dashboard-Generation-Agent-in-Databricks- --skill databricks-zerobus-ingest-ice-droid-99

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes references (resource) components.

What problem does it solve?

It helps you ingest near real-time records directly into Databricks managed Delta tables by using Zerobus Ingest, avoiding message-bus plumbing while still getting durability acknowledgments.

Core Features & Use Cases

  • Direct Delta ingestion via gRPC: Push records into Unity Catalog managed Delta tables using the Zerobus Ingest SDK.
  • Protobuf-first schema safety: Generate and compile Protobuf schemas from Unity Catalog tables to keep producer and table schemas aligned.
  • Operational reliability: Handle ACKs, retries, reconnections, throughput limits, and at-least-once delivery semantics (including duplicate-handling guidance).

Quick Start

Run the skill to generate a Protobuf schema from your Unity Catalog table, then produce and ingest Protobuf records into a pre-created managed Delta table using a Zerobus Ingest SDK client.

Frequently Asked Questions about databricks-zerobus-ingest

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I stream data into Delta tables using gRPC ingestion?

Stream data into Delta tables using gRPC ingestion by building Zerobus Ingest clients that push records directly into Unity Catalog managed Delta tables while relying on durability acknowledgments for delivery reliability.

What is the best way to keep producer schemas aligned with Unity Catalog tables?

To keep producer schemas aligned with Unity Catalog tables, generate and compile Protobuf schemas directly from the UC tables before producing records, ensuring type safety across Python, Java, Go, TypeScript, and Rust clients.

Do I need pre-created managed Delta tables before using Zerobus ingest?

Yes, Zerobus ingest requires pre-created managed Delta tables in Unity Catalog, supported region endpoints, and explicit service-principal MODIFY/SELECT grants to successfully write near real-time records.

How does Zerobus ingest handle ACK tracking and at-least-once delivery?

Zerobus ingest handles ACK tracking and at-least-once delivery by managing operational patterns like retries, reconnections, and throughput limits, while providing duplicate-handling guidance for stream-based ingestion with flush/close semantics.

Can I use JSON records instead of Protobuf for Delta table ingestion?

You can ingest JSON records, but Zerobus ingest is Protobuf-first, requiring correct JSON versus Protobuf handling to ensure your producer schemas match the Unity Catalog managed Delta table structure.