hub / github.com/delta-io/kafka-delta-ingest

github.com/delta-io/kafka-delta-ingest @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

359 symbols 968 edges 22 files ⚖ Apache-2.0 109 documented · 30% ● updated 2mo ago★ 44130 open issues

Browse by type

⨍ Functions 298◇ Types & classes 61

What it actually does AI analysis from the code graph — generated when you open this

loading…

Extension points exported contracts — how you extend this code

MessageDeserializer (Interface)

(no doc) [5 implementers]

src/serialization.rs

DeadLetterQueue (Interface)

(no doc) [3 implementers]

src/dead_letters.rs

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 3 filesload_table

src/delta_helpers.rs

↓ 2 filesstart_ingest

Executes a run loop to consume from a Kafka topic and write to a Delta table.

src/lib.rs

↓ 2 filestxn_app_id_for_partition

src/delta_helpers.rs

↓ 2 filestry_create_checkpoint

src/delta_helpers.rs

browse all functions →

Shape

Function 187

Method 111

Class 40

Enum 19

Interface 2

Languages

Rust100%

Modules by API surface

src/lib.rs46 symbols

tests/helpers/mod.rs40 symbols

src/transforms.rs40 symbols

src/writer.rs39 symbols

src/metrics.rs25 symbols

src/cursor.rs22 symbols

src/serialization.rs19 symbols

src/main.rs19 symbols

tests/deserialization_tests.rs15 symbols

src/dead_letters.rs15 symbols

src/value_buffers.rs11 symbols

src/coercions.rs11 symbols

For agents

$ claude mcp add kafka-delta-ingest \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/delta-io/kafka-delta-ingest @main

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

For agents

Ask about this repo answers extend the page