hub / github.com/dibbhatt/kafka-spark-consumer

github.com/dibbhatt/kafka-spark-consumer @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

195 symbols 387 edges 33 files 5 documented · 3% ● updated 4mo ago★ 6311 open issues

Browse by type

⨍ Functions 161◇ Types & classes 34

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

PartitionCoordinator (Interface)

(no doc) [2 implementers]

src/main/java/consumer/kafka/PartitionCoordinator.java

IBrokerReader (Interface)

(no doc) [2 implementers]

src/main/java/consumer/kafka/IBrokerReader.java

BrokerHosts (Interface)

(no doc)

src/main/java/consumer/kafka/BrokerHosts.java

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 7 filesMessageAndMetadata

src/main/java/consumer/kafka/MessageAndMetadata.java

↓ 6 filesZkState

src/main/java/consumer/kafka/ZkState.java

↓ 4 filesIBrokerReader

src/main/java/consumer/kafka/IBrokerReader.java

↓ 4 filesKafkaMessageHandler

src/main/java/consumer/kafka/KafkaMessageHandler.java

↓ 4 filesGlobalPartitionInformation

src/main/java/consumer/kafka/GlobalPartitionInformation.java

↓ 4 filesDynamicPartitionConnections

src/main/java/consumer/kafka/DynamicPartitionConnections.java

browse all functions →

Shape

Method 161

Class 30

Interface 3

Enum 1

Languages

Java100%

Modules by API surface

src/main/java/consumer/kafka/PartitionManager.java18 symbols

src/main/java/consumer/kafka/ReceiverStreamListener.java13 symbols

src/main/java/consumer/kafka/MessageAndMetadata.java13 symbols

src/main/java/consumer/kafka/GlobalPartitionInformation.java13 symbols

src/main/java/consumer/kafka/ProcessedOffsetManager.java10 symbols

src/test/java/consumer/kafka/PIDControllerTest.java9 symbols

src/main/java/consumer/kafka/ZkState.java9 symbols

src/main/java/consumer/kafka/DynamicBrokersReader.java9 symbols

src/main/java/consumer/kafka/DynamicPartitionConnections.java8 symbols

src/main/java/consumer/kafka/Broker.java7 symbols

src/main/java/consumer/kafka/client/KafkaReceiver.java6 symbols

src/main/java/consumer/kafka/client/KafkaRangeReceiver.java6 symbols

For agents

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

⬇ download graph artifact

github.com/dibbhatt/kafka-spark-consumer @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