hub / github.com/endgameinc/elasticsearch-river-kafka

github.com/endgameinc/elasticsearch-river-kafka @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

100 symbols 242 edges 19 files 5 documented · 5%

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

MessageHandlerFactory (Interface)

(no doc) [3 implementers]

src/main/java/org/elasticsearch/river/kafka/MessageHandlerFactory.java

Core symbols most depended-on inside this repo

get

called by 20

src/main/java/org/elasticsearch/river/kafka/KafkaClient.java

isEnabled

called by 5

src/main/java/org/elasticsearch/river/kafka/StatsReporter.java

called by 4

src/main/java/org/elasticsearch/river/kafka/KafkaRiver.java

getOldestOffset

called by 3

src/main/java/org/elasticsearch/river/kafka/KafkaClient.java

fetch

called by 3

src/main/java/org/elasticsearch/river/kafka/KafkaClient.java

reoportStats

called by 3

src/main/java/org/elasticsearch/river/kafka/StatsReporter.java

reset

called by 3

src/main/java/org/elasticsearch/river/kafka/Stats.java

readMessage

called by 3

src/main/java/org/elasticsearch/river/kafka/JsonMessageHandler.java

Shape

Method 79

Class 20

Interface 1

Languages

Java100%

Modules by API surface

src/test/java/org/elasticsearch/river/kafka/KafkaClientTest.java19 symbols

src/main/java/org/elasticsearch/river/kafka/KafkaRiver.java18 symbols

src/main/java/org/elasticsearch/river/kafka/KafkaClient.java11 symbols

src/main/java/org/elasticsearch/river/kafka/JsonMessageHandler.java9 symbols

src/test/java/org/elasticsearch/river/kafka/JsonMessageHandlerTest.java5 symbols

src/main/java/org/elasticsearch/plugin/river/kafka/KafkaRiverPlugin.java5 symbols

src/test/java/org/elasticsearch/river/kafka/StatsReporterTest.java4 symbols

src/main/java/org/elasticsearch/river/kafka/StatsReporter.java4 symbols

src/test/java/org/elasticsearch/river/kafka/KafkaRiverConfigTest.java3 symbols

src/main/java/org/elasticsearch/river/kafka/Stats.java3 symbols

src/main/java/org/elasticsearch/river/kafka/MessageHandler.java3 symbols

src/test/java/org/elasticsearch/river/kafka/StatsTest.java2 symbols

For agents

$ claude mcp add elasticsearch-river-kafka \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/endgameinc/elasticsearch-river-kafka @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