MCPcopy Index your code
hub / github.com/apache/rocketmq-connect

github.com/apache/rocketmq-connect @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
7,209 symbols 24,288 edges 1,054 files 1,159 documented · 16%
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

Callback (Interface)
Generic interface for callbacks [7 implementers]
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Callback.java
IReporter (Interface)
astrict reporter [143 implementers]
metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/IReporter.java
Auth (Interface)
(no doc) [6 implementers]
connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/auth/Auth.java
SubCommand (Interface)
(no doc) [22 implementers]
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/SubCommand.java
TaskClassSetter (Interface)
task class setter [3 implementers]
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/task/TaskClassSetter.java
DeltalakeWriter (Interface)
@author osgoo @date 2022/8/23 [3 implementers]
connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/writer/DeltalakeWriter.java
backoffFunction (Interface)
Interfaces to define the lambda function to be used by backoffAndRetry [2 implementers]
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/utils/BackoffAndRetryUtils.java
DatabaseDialectFactory (Interface)
(no doc) [4 implementers]
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectFactory.java

Core symbols most depended-on inside this repo

put
called by 1382
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/cache/Cache.java
get
called by 911
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/cache/Cache.java
add
called by 622
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java
getString
called by 531
connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/config/ConnectKeyValue.java
error
called by 414
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ProcessingContext.java
append
called by 406
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java
size
called by 289
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/cache/Cache.java
getKey
called by 286
connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java

Shape

Method 6,031
Class 1,055
Interface 69
Enum 48
Function 6

Languages

Java100%
Python1%

Modules by API surface

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java104 symbols
connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java94 symbols
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java93 symbols
rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/record/JsonConverterTest.java72 symbols
schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java65 symbols
connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java50 symbols
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java49 symbols
connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java48 symbols
connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/cfg/DorisOptions.java47 symbols
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java42 symbols
connectors/rocketmq-connect-deltalake/src/main/java/example/avro/User.java39 symbols
rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java38 symbols

Datastores touched

(mysql)Database · 1 repos
(mongodb)Database · 1 repos
bank1Database · 1 repos
inventory_2Database · 1 repos
test_database_001Database · 1 repos

For agents

$ claude mcp add rocketmq-connect \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact