hub / github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing

github.com/LearningJournal/Kafka-Streams-Real-time-Stream-Processing @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

2,170 symbols 3,151 edges 199 files 860 documented · 40%

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

loading…

Core symbols most depended-on inside this repo

put

called by 143

avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java

getName

called by 31

ktable-aggregate/src/main/java/guru/learningjournal/kafka/examples/types/Employee.java

get

called by 30

avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java

start

called by 30

ktable-aggregate-query/src/main/java/guru/learningjournal/kafka/examples/AppRestService.java

build

called by 20

avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java

add

called by 18

top3-inventories/src/main/java/guru/learningjournal/kafka/examples/common/Top3NewsTypes.java

put

called by 14

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java

put

called by 9

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java

Shape

Method 1,924

Class 246

Languages

Java100%

Modules by API surface

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java117 symbols

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java117 symbols

pos-fanout-avro/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java102 symbols

avro-producer/src/main/java/guru/learningjournal/kafka/examples/StockData.java90 symbols

avro-consumer/src/main/java/guru/learningjournal/kafka/examples/StockData.java90 symbols

time-check/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java53 symbols

rewards-table/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java53 symbols

rewards-in-memory/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java53 symbols

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/PosInvoice.java53 symbols

pos-fanout/src/main/java/guru/learningjournal/kafka/examples/types/HadoopRecord.java47 symbols

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/PosLineItem.java42 symbols

pos-simulator-avro/src/main/java/guru/learningjournal/kafka/examples/types/DeliveryAddress.java42 symbols

For agents

$ claude mcp add Kafka-Streams-Real-time-Stream-Processing \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact