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% ● updated 3mo ago★ 141119 open issues

Browse by type

⨍ Functions 6,037◇ Types & classes 1,172

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

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 359 filesCache

cache @param @param

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/cache/Cache.java

↓ 226 filesBufferedRecords

buffered records

connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java

↓ 149 filesIReporter

astrict reporter

metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/IReporter.java

↓ 179 filesKVEntry

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java

↓ 128 filesKeyValueStore

Key value based store interface. @param @param

rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java

↓ 90 filesRedisEventProcessor

connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java

browse all functions →

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

github.com/apache/rocketmq-connect @main

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

Datastores touched

For agents

Ask about this repo answers extend the page