hub / github.com/bjpublic/apache-kafka-with-java

github.com/bjpublic/apache-kafka-with-java @main

203 symbols 420 edges 61 files 0 documented · 0% ● updated 2y ago★ 2321 open issues

Browse by type

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

loading…

Core symbols most depended-on inside this repo

Method 138

Class 65

Java100%

Chapter5/5.1 web-page-event-pipeline/kafka-multi-consumer-thread-hdfs-save/src/main/java/com/pipeline/consumer/ConsumerWorker.java9 symbols

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkTask.java8 symbols

Chapter5/5.1 web-page-event-pipeline/elasticsearch-kafka-connector/src/main/java/com/pipeline/ElasticSearchSinkConnector.java7 symbols

Chapter4/4.4 spring-kafka/spring-kafka-record-listener/src/main/java/com/example/SpringConsumerApplication.java7 symbols

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceConnector.java7 symbols

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkConnector.java7 symbols

Chapter4/4.4 spring-kafka/spring-kafka-listener-container/src/main/java/com/example/ListenerContainerConfiguration.java6 symbols

Chapter4/4.3 kafka-consumer/kafka-multi-consumer-thread-by-partition/src/main/java/com/example/MultiConsumerThreadByPartition.java6 symbols

Chapter3/3.6 kafka-connector/simple-source-connector/src/main/java/com/example/SingleFileSourceTask.java6 symbols

Chapter3/3.6 kafka-connector/simple-sink-connector/src/main/java/com/example/SingleFileSinkTask.java6 symbols

Chapter5/5.1 web-page-event-pipeline/kafka-spring-producer-with-rest-controller/src/main/java/com/pipeline/ProduceController.java5 symbols

Chapter4/4.4 spring-kafka/spring-kafka-template-producer/src/main/java/com/example/SpringProducerApplication.java5 symbols

$ claude mcp add apache-kafka-with-java \
  -- python -m otcore.mcp_server <graph>