apache/rocketmq-flink
View on GitHubRocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
- Stars
- 174
- Forks
- 104
- Open beginner issues
- 0
- Indexed issues
- 37
- Dominant language
- Java
- License
- Apache-2.0
- Last GitHub push
- Aug 13, 2026
- Latest indexed
- Sep 14, 2026
- Contributing guide
- No contributing guide
- Code of conduct
- Code of conduct
- Beginner labels
- help wanted
- PR merge metrics
- No merged PRs in 30d
-
help wanted
apache/rocketmq-flink#1 · 8 comments · 7 reactions · 0 assignees ·
-
enhancement
apache/rocketmq-flink#6 · 0 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#48 · 0 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#53 · 2 comments · 0 reactions · 0 assignees ·
-
disscuss
apache/rocketmq-flink#55 · 1 comment · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#56 · 1 comment · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#63 · 2 comments · 0 reactions · 1 assignee ·
-
apache/rocketmq-flink#64 · 1 comment · 0 reactions · 1 assignee ·
-
apache/rocketmq-flink#69 · 7 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#73 · 1 comment · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#75 · 2 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#78 · 2 comments · 0 reactions · 0 assignees ·
-
bug
apache/rocketmq-flink#79 · 4 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#80 · 2 comments · 2 reactions · 1 assignee ·
-
apache/rocketmq-flink#81 · 4 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#83 · 6 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#87 · 1 comment · 1 reaction · 0 assignees ·
-
apache/rocketmq-flink#88 · 1 comment · 2 reactions · 0 assignees ·
-
apache/rocketmq-flink#93 · 1 comment · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#97 · 3 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#99 · 3 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#100 · 1 comment · 1 reaction · 0 assignees ·
-
apache/rocketmq-flink#101 · 1 comment · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#103 · 0 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#107 · 9 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#108 · 4 comments · 0 reactions · 0 assignees ·
-
How to get it? Open
apache/rocketmq-flink#109 · 1 comment · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#110 · 1 comment · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#111 · 0 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#115 · 1 comment · 1 reaction · 0 assignees ·
-
apache/rocketmq-flink#116 · 0 comments · 0 reactions · 0 assignees ·
-
Version help Open
apache/rocketmq-flink#122 · 1 comment · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#125 · 0 comments · 1 reaction · 0 assignees ·
-
apache/rocketmq-flink#127 · 0 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#130 · 0 comments · 0 reactions · 0 assignees ·
-
package error Open
apache/rocketmq-flink#132 · 0 comments · 0 reactions · 0 assignees ·
-
apache/rocketmq-flink#137 · 0 comments · 0 reactions · 0 assignees ·