hub / github.com/bbejeck/KafkaStreamsInAction2ndEdition

github.com/bbejeck/KafkaStreamsInAction2ndEdition @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

1,049 symbols 3,630 edges 221 files 132 documented · 13%

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

DataSource (Interface)

Interface for providing a data source for examples [3 implementers]

streams/src/main/java/bbejeck/data/DataSource.java

RecordProcessor (Interface)

Interface that provides for accepting ConsumerRecords for processing, possibly in an asynchronous manner. Also [1 implementers]

streams/src/main/java/bbejeck/data/RecordProcessor.java

ConsumerRecordsHandler (Interface)

Interface used to inject record handling into various consumer clients throughout the examples

streams/src/main/java/bbejeck/clients/ConsumerRecordsHandler.java

Core symbols most depended-on inside this repo

build

called by 229

spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java

newBuilder

called by 154

spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java

get

called by 124

streams/src/main/java/bbejeck/chapter_10/PopsHopsApplication.java

start

called by 65

custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java

protobufSerde

called by 58

streams/src/main/java/bbejeck/utils/SerdeUtil.java

maybeDeleteThenCreate

called by 43

streams/src/main/java/bbejeck/utils/Topics.java

send

called by 39

streams/src/main/java/bbejeck/chapter_3/producer/BaseProducer.java

create

called by 38

streams/src/main/java/bbejeck/utils/Topics.java

Shape

Method 814

Class 230

Interface 3

Enum 2

Languages

Java100%

Modules by API surface

streams/src/main/java/bbejeck/data/DataGenerator.java22 symbols

spring-kafka/src/main/java/bbejeck/spring/model/LoanApplication.java21 symbols

streams/src/main/java/bbejeck/clients/MockDataProducer.java19 symbols

streams/src/main/java/bbejeck/chapter_9/IotSensorAggregation.java19 symbols

custom-connector/src/main/java/bbejeck/chapter_5/transformer/MultiFieldExtract.java19 symbols

custom-connector/src/main/java/bbejeck/chapter_5/connector/StockTickerSourceTask.java13 symbols

streams/src/test/java/bbejeck/chapter_6/ZMartKafkaStreamsFilteringBranchingAppTest.java12 symbols

spring-kafka/src/main/java/bbejeck/spring/model/QueryResponse.java12 symbols

streams/src/test/java/bbejeck/chapter_4/IdempotentProducerTest.java11 symbols

streams/src/test/java/bbejeck/chapter_4/TransactionalProducerConsumerTest.java10 symbols

streams/src/main/java/bbejeck/chapter_3/model/User.java10 symbols

spring-kafka/src/main/java/bbejeck/spring/streams/boot/KafkaStreamsBootLoanApplicationApplication.java10 symbols

Datastores touched

postgresDatabase · 1 repos

For agents

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

⬇ download graph artifact