MCPcopy Create free account
hub / github.com/beyondj2ee/flumeng-kafka-plugin

github.com/beyondj2ee/flumeng-kafka-plugin @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
34 symbols 85 edges 8 files 34 documented · 100% ● updated 10y ago★ 752 open issues

Browse by type

⨍ Functions 24◇ Types & classes 10
What it actually does AI analysis from the code graph — generated when you open this
loading…

Core symbols most depended-on inside this repo

browse all functions →

Shape

Method 24
Class 10

Languages

Java100%

Modules by API surface

flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java8 symbols
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/ConsumerChecker.java7 symbols
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSourceTest.java5 symbols
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSink.java5 symbols
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSinkTest.java4 symbols
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/SinglePartition.java3 symbols
flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/JunitConstans.java1 symbols
flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaFlumeConstans.java1 symbols

For agents

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

⬇ download graph artifact

Ask about this repo answers extend the page