hub / github.com/ajmalbabu/kafka-clients

github.com/ajmalbabu/kafka-clients @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

52 symbols 97 edges 10 files 14 documented · 27% 29 cross-repo links ● updated 9y ago★ 511 open issues

Browse by type

⨍ Functions 42 ◇ Types & classes 10

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

loading…

Core symbols most depended-on inside this repo

↓ 3 filesOffsetManager

The partition offset are stored in an external storage. In this case in a file system.

src/main/java/poc/OffsetManager.java

↓ 2 filesAvroSupport

Support class for avro messages.

src/main/java/poc/AvroSupport.java

browse all functions →

Shape

Method 42

Class 10

Languages

Java100%

Modules by API surface

src/main/java/poc/ExactlyOnceStaticConsumer.java6 symbols

src/main/java/poc/AvroProducerExample.java6 symbols

src/main/java/poc/AtMostOnceConsumer.java6 symbols

src/main/java/poc/AtLeastOnceConsumer.java6 symbols

src/main/java/poc/OffsetManager.java5 symbols

src/main/java/poc/ExactlyOnceDynamicConsumer.java5 symbols

src/main/java/poc/AvroSupport.java5 symbols

src/main/java/poc/AvroConsumerExample.java5 symbols

src/main/java/poc/ProducerExample.java4 symbols

src/main/java/poc/MyConsumerRebalancerListener.java4 symbols

Used by 29 indexed graphs manifest dependencies, hub-wide

github.com/Graylog2/graylog2-server

github.com/alibaba/canal

github.com/apache/doris

github.com/apache/druid

github.com/apache/flink

github.com/apache/hertzbeat

github.com/apache/hudi

github.com/apache/incubator-seata

github.com/apache/logging-log4j2

github.com/apache/seatunnel

… +19 more

For agents

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

⬇ download graph artifact

github.com/ajmalbabu/kafka-clients @main

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

Used by 29 indexed graphs manifest dependencies, hub-wide

For agents

Ask about this repo answers extend the page