apache/rocketmq-flink

View on GitHub

RocketMQ 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

Beginner friendly Everything

Open All

37 open issues indexed

Support normal-topic consumption with the gRPC SimpleConsumer Open

Difficulty 4/5 3-5 days Newbie friendliness 48/100

apache/rocketmq-flink#137 · Opened Aug 17, 2026
package error Open

Difficulty 4/5 3-5 days Newbie friendliness 20/100

apache/rocketmq-flink#132 · Opened Jul 3, 2026
Safer - Compatible Updates to Fix Vulnerable Dependencies Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#130 · Opened Jul 16, 2025
What versions of Flink are supported? Open

Difficulty 2/5 1-3 hours Newbie friendliness 35/100

apache/rocketmq-flink#127 · Opened Jan 13, 2025
[Feature][RIP-74] Rocketmq-flink dynamic load balancing Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/rocketmq-flink#125 · 1 reaction · Opened Dec 26, 2024
Version help Open

Difficulty 3/5 1-2 days Newbie friendliness 32/100

apache/rocketmq-flink#122 · 1 comment · Opened Jul 17, 2024
[Bug] Some messages cannot be consumed if there's new queues added. Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/rocketmq-flink#116 · Opened Apr 12, 2024
Sql Source is no longer compatible. Open

Difficulty 3/5 1-2 days Newbie friendliness 45/100

apache/rocketmq-flink#115 · 1 comment · 1 reaction · Opened Mar 27, 2024
Add some metrics so that they can be monitored on aliyun vvp Open

Difficulty 4/5 3-5 days Newbie friendliness 20/100

apache/rocketmq-flink#111 · Opened Mar 14, 2024
How to set nameServerAddress Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#110 · 1 comment · Opened Mar 11, 2024
How to get it? Open

Difficulty 2/5 1-3 hours Newbie friendliness 15/100

apache/rocketmq-flink#109 · 1 comment · Opened Mar 5, 2024
roketmq can not consumer topic in cluster, it's ok in idea Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#108 · 4 comments · Opened Jan 5, 2024
The message queue is not in assigned list Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#107 · 9 comments · Opened Dec 28, 2023
[BUG] some bug in newSource Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/rocketmq-flink#103 · Opened Nov 26, 2023
[BUG] If the optional param 'startup.offset.timestamp' is not set, a NullPointerException will be thrown. Open

Difficulty 3/5 1-2 days Newbie friendliness 25/100

apache/rocketmq-flink#101 · 1 comment · Opened Nov 15, 2023
Run on k8s, it's throw RemotingTimeoutException Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#100 · 1 comment · 1 reaction · Opened Sep 5, 2023
why 'nameServerAddress' option unsupported? Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

apache/rocketmq-flink#99 · 3 comments · Opened Aug 21, 2023
RocketMQSourceFunction doesn't have the ability to dynamically sense topic routing changes. Open

Difficulty 4/5 3-5 days Newbie friendliness 28/100

apache/rocketmq-flink#97 · 3 comments · Opened Aug 10, 2023
Implement new flink-connector-rocketmq base on FLIP-27/FLIP-191 Open

Difficulty 5/5 Over a week Newbie friendliness 15/100

apache/rocketmq-flink#93 · 1 comment · Opened Jul 14, 2023
Introduce format parameter configuration to support different serialization and deserialization formats provided by Flink Open

Difficulty 4/5 3-5 days Newbie friendliness 42/100

apache/rocketmq-flink#88 · 1 comment · 2 reactions · Opened Apr 23, 2023
Introduce a separate SQL module for shading the dependencies. Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/rocketmq-flink#87 · 1 comment · 1 reaction · Opened Apr 22, 2023
[BUG] topic route changed,job can't recover normally Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/rocketmq-flink#83 · 6 comments · Opened Jan 17, 2023
Consumption duplication Open

Difficulty 4/5 3-5 days Newbie friendliness 20/100

apache/rocketmq-flink#81 · 4 comments · Opened Dec 13, 2022
Support rocketmq v5 client Open

apache/rocketmq-flink#80 · 2 comments · 2 reactions · 1 assignee · Opened Dec 5, 2022
The message queue is not in assigned list Open

bug

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#79 · 4 comments · Opened Dec 1, 2022
Some problems found by individuals during use Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#78 · 2 comments · Opened Nov 30, 2022
I have a question about DEFAULT_START_MESSAGE_OFFSET Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#75 · 2 comments · Opened Nov 22, 2022
[doc] Miss introduction of RocketMQSource. Open

Difficulty 1/5 Under an hour Newbie friendliness 25/100

apache/rocketmq-flink#73 · 1 comment · Opened Nov 16, 2022
Version below 4.6.0 does not support DefaultLitePullConsumer Open

Difficulty 4/5 3-5 days Newbie friendliness 30/100

apache/rocketmq-flink#69 · 7 comments · Opened Oct 27, 2022
Support RocketMQ as LogStore for Flink Table Store Open

apache/rocketmq-flink#64 · 1 comment · 1 assignee · Opened Oct 11, 2022
Support rich initialization modes of RocketMQSource Open

apache/rocketmq-flink#63 · 2 comments · 1 assignee · Opened Oct 10, 2022
Port RocketMQSink to FLIP-143 Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/rocketmq-flink#56 · 1 comment · Opened Aug 27, 2022
[Polish] Move example code to somewhere? Open

disscuss

Difficulty 4/5 3-5 days Newbie friendliness 20/100

apache/rocketmq-flink#55 · 1 comment · Opened Aug 27, 2022
org.apache.rocketmq:schema-registry-client non-existent Open

Difficulty 3/5 1-2 days Newbie friendliness 25/100

apache/rocketmq-flink#53 · 2 comments · Opened Aug 23, 2022
Diff flink version support Open

Difficulty 5/5 Over a week Newbie friendliness 20/100

apache/rocketmq-flink#48 · Opened Aug 2, 2022
Message order needs to be guaranteed Open

enhancement

Difficulty 5/5 Over a week Newbie friendliness 15/100

apache/rocketmq-flink#6 · Opened Sep 22, 2021
Are you using RocketMQ Flink? Open

help wanted

Difficulty 1/5 Under an hour Newbie friendliness 25/100

apache/rocketmq-flink#1 · 8 comments · 7 reactions · Opened Aug 24, 2021

apache/rocketmq-flink

Get new issues in your inbox