MCPcopy Index your code
hub / github.com/amient/kafka-metrics

github.com/amient/kafka-metrics @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
171 symbols 427 edges 29 files 3 documented · 2% ● updated 7y ago★ 10711 open issues
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

MeasurementPublisher (Interface)
(no doc) [5 implementers]
core/src/main/java/io/amient/kafka/metrics/MeasurementPublisher.java
ConsumerGroupReporterMBean (Interface)
(no doc)
metrics-reporter/src/main/java/io/amient/kafka/metrics/ConsumerGroupReporterMBean.java
TopicReporterMBean (Interface)
(no doc)
metrics-reporter/src/main/java/io/amient/kafka/metrics/TopicReporterMBean.java

Core symbols most depended-on inside this repo

put
called by 262
metrics-connect/src/main/java/io/amient/kafka/metrics/InfluxDbSinkTask.java
get
called by 23
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java
toString
called by 17
core/src/main/java/io/amient/kafka/metrics/MeasurementFormatter.java
newTarget
called by 16
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java
get
called by 15
metrics-reporter/src/main/java/io/amient/kafka/metrics/GroupMetrics.java
getTags
called by 13
core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java
newGraph
called by 11
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java
close
called by 9
core/src/main/java/io/amient/kafka/metrics/MeasurementPublisher.java

Shape

Method 135
Class 32
Interface 3
Enum 1

Languages

Java100%

Modules by API surface

core/src/main/java/io/amient/kafka/metrics/JMXScannerTask.java14 symbols
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessor.java13 symbols
discovery/src/main/java/io/amient/kafka/metrics/Dashboard.java13 symbols
metrics-reporter/src/main/java/io/amient/kafka/metrics/KafkaMetricsProcessorBuilder.java11 symbols
metrics-reporter/src/main/java/io/amient/kafka/metrics/ConsumerGroupReporter.java11 symbols
core/src/main/java/io/amient/kafka/metrics/ProducerPublisher.java11 symbols
discovery/src/main/java/io/amient/kafka/metrics/DiscoveryTool.java10 symbols
influxdb-loader/src/main/java/io/amient/kafka/metrics/ConsumerMetrics.java9 symbols
metrics-reporter/src/main/java/io/amient/kafka/metrics/TopicReporter.java7 symbols
metrics-connect/src/main/java/io/amient/kafka/metrics/InfluxDbSinkConnector.java7 symbols
metrics-connect/src/main/java/io/amient/kafka/metrics/InfluxDbSinkTask.java6 symbols
core/src/main/java/io/amient/kafka/metrics/MeasurementFormatter.java6 symbols

For agents

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

⬇ download graph artifact

Ask about this repo answers extend the page