MCPcopy Index your code
hub / github.com/AliwareMQ/aliware-kafka-demos

github.com/AliwareMQ/aliware-kafka-demos @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
318 symbols 676 edges 128 files 52 documented · 16% ● updated 2y ago★ 43425 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

Cmd (Interface)
(no doc) [5 implementers]
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java
MyOutput (Interface)
(no doc)
kafka-spring-stream-demo/sasl-ssl/src/main/java/com/alibaba/cloud/MyOutput.java
MyOutput (Interface)
(no doc)
kafka-spring-stream-demo/vpc/src/main/java/com/alibaba/cloud/MyOutput.java
MyInput (Interface)
(no doc)
kafka-spring-stream-demo/sasl-ssl/src/main/java/com/alibaba/cloud/MyInput.java
MyInput (Interface)
(no doc)
kafka-spring-stream-demo/vpc/src/main/java/com/alibaba/cloud/MyInput.java

Core symbols most depended-on inside this repo

log
called by 60
kafka-spring-stream-demo/vpc/src/main/java/com/alibaba/cloud/KafkaDemoApplication.java
isEmpty
called by 14
kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java
sleep
called by 10
kafka-migration/src/main/java/com/alibaba/migration/cmd/AbstractMigration.java
run
called by 7
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java
close
called by 6
kafka-streams-demo/vpc/src/main/java/streams/JsonPOJOSerializer.java
buildAcsClient
called by 6
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java
getKafkaProperties
called by 5
kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java
getKafkaProperties
called by 5
kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/JavaKafkaConfigurer.java

Shape

Method 165
Class 90
Function 50
Struct 8
Interface 5

Languages

Java73%
Go11%
C10%
TypeScript3%
C#3%
Python1%

Modules by API surface

kafka-streams-demo/vpc/src/main/java/streams/BagChecker.java17 symbols
kafka-cpp-demo/vpc/kafka_consumer.c13 symbols
kafka-cpp-demo/vpc-ssl/kafka_consumer.c13 symbols
kafka-go-demo/consumer/consumer.go9 symbols
kafka-migration/src/main/java/com/alibaba/migration/cmd/Cmd.java8 symbols
kafka-migration/src/main/java/com/alibaba/migration/Migration.java7 symbols
kafka-migration/src/main/java/com/alibaba/migration/cmd/TopicMigrationFromZk.java6 symbols
kafka-java-demo/vpc/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java6 symbols
kafka-java-demo/vpc-ssl/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java6 symbols
kafka-java-demo/vpc-9094/src/main/java/com/aliyun/openservices/kafka/ons/KafkaMultiConsumerDemo.java6 symbols
kafka-streams-demo/vpc/src/main/java/streams/JsonPOJOSerializer.java5 symbols
kafka-streams-demo/vpc/src/main/java/streams/JsonPOJODeserializer.java5 symbols

Datastores touched

(mysql)Database · 1 repos

For agents

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

⬇ download graph artifact