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 109 documented · 30% ● updated 16d ago★ 43730 open issues

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

Core symbols most depended-on inside this repo

len

called by 21

src/cursor.rs

wait_until_version_created

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