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

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

loading…

Core symbols most depended-on inside this repo

saveOffsetInExternalStore

called by 3

src/main/java/poc/OffsetManager.java

getSchema

called by 3

src/main/java/poc/AvroSupport.java

readOffsetFromExternalStore

called by 2

src/main/java/poc/OffsetManager.java

storageName

called by 2

src/main/java/poc/OffsetManager.java

sendMessages

called by 1

src/main/java/poc/ProducerExample.java

createProducer

called by 1

src/main/java/poc/ProducerExample.java

execute

called by 1

src/main/java/poc/AtLeastOnceConsumer.java

createConsumer

called by 1

src/main/java/poc/AtLeastOnceConsumer.java

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