databricks-zerobus-ingest

Build Zerobus Ingest clients to stream data into Databricks Delta tables via gRPC.

4|2|Updated Feb 16, 2026
One-click install
npx skills add https://github.com/alessandro9110/Speech-To-Text-With-Databricks --skill databricks-zerobus-ingest-alessandro9110
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: databricks-zerobus-ingest
Source: https://github.com/alessandro9110/Speech-To-Text-With-Databricks/tree/main/.claude/skills/databricks-zerobus-ingest
Command: npx skills add https://github.com/alessandro9110/Speech-To-Text-With-Databricks --skill databricks-zerobus-ingest-alessandro9110

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill includes scripts (resource) and references (resource) components.

What problem does it solve?

This Skill streamlines the process of ingesting data directly into Databricks Delta tables, eliminating the need for intermediate message bus infrastructure and simplifying real-time data pipelines.

Core Features & Use Cases

  • Direct Ingestion: Write data record-by-record into Unity Catalog managed Delta tables using the Zerobus gRPC API.
  • Multi-Language Support: Build producers in Python, Java, Go, TypeScript, or Rust.
  • Schema Management: Generate Protobuf schemas from Unity Catalog tables for type-safe data ingestion.
  • Use Case: A sensor network generating high-velocity data needs to be ingested into a Databricks lakehouse for real-time analytics. This Skill enables building a producer application that directly streams this data into a Delta table without setting up Kafka or Kinesis.

Quick Start

Use the databricks-zerobus-ingest skill to ingest JSON data into your Unity Catalog table 'my_catalog.my_schema.my_events' using the provided service principal credentials.

Frequently Asked Questions about databricks-zerobus-ingest

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

FAQPage Schema
How do I ingest real-time data directly into Databricks Delta tables without using Kafka?

You can ingest real-time data directly into Databricks Delta tables by building a Zerobus Ingest client that streams records via gRPC into Unity Catalog managed tables, eliminating the need for intermediate message bus infrastructure like Kafka.

Can I generate Protobuf schemas from Unity Catalog tables for data ingestion?

Yes, you can generate Protobuf schemas directly from Unity Catalog tables to enable type-safe data ingestion. This allows producers to write structured records into Delta tables using the Zerobus Ingest SDK.

What programming languages are supported for building Databricks gRPC ingestion producers?

You can build gRPC ingestion producers for Databricks Delta tables using Python, Java, Go, TypeScript, or Rust with the Zerobus Ingest SDK to stream data directly into Unity Catalog.

Does the Zerobus Ingest SDK handle stream ingestion failures and retries?

Yes, the Zerobus Ingest SDK implements stream-based ingestion with ACK handling and retry logic to ensure high-velocity sensor data or event records are reliably written into Databricks Delta tables.

Is Databricks Unity Catalog required for direct gRPC data ingestion?

Yes, Unity Catalog is required because the Zerobus gRPC API writes data record-by-record directly into Unity Catalog managed Delta tables to facilitate near real-time lakehouse analytics.