Skip to content

Issues: apache/rocketmq-flink

Are you using RocketMQ Flink?
#1 opened Aug 24, 2021 by SteNicholas
Open 8
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

33 Open 36 Closed
33 Open 36 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

[Bug] Some messages cannot be consumed if there's new queues added.
#116 opened Apr 12, 2024 by humkum
1
Sql Source is no longer compatible.
#115 opened Mar 27, 2024 by loserwang1024
1
In new api, what's the way to pass parameters?
#114 opened Mar 25, 2024 by humkum
1
[Bug] unbalanced assignment caused by hash collision in ConsistentHashAllocateStrategy.java
#113 opened Mar 22, 2024 by humkum
@humkum
1
Add some metrics so that they can be monitored on aliyun vvp
#111 opened Mar 14, 2024 by ArthurWrong
How to set nameServerAddress
#110 opened Mar 11, 2024 by cj495840252
1
How to get it?
#109 opened Mar 5, 2024 by anonymous-shy
1
roketmq can not consumer topic in cluster, it's ok in idea
#108 opened Jan 5, 2024 by luckydarnell
4
The message queue is not in assigned list
#107 opened Dec 28, 2023 by andyyumiao
7
[BUG] some bug in newSource
#103 opened Nov 26, 2023 by 844028312
[BUG] If the optional param 'startup.offset.timestamp' is not set, a NullPointerException will be thrown.
#101 opened Nov 15, 2023 by leosanqing
1
Run on k8s, it's throw RemotingTimeoutException
#100 opened Sep 5, 2023 by SOD-DOB
1
why 'nameServerAddress' option unsupported?
#99 opened Aug 21, 2023 by kevinnerd
3
RocketMQSourceFunction doesn't have the ability to dynamically sense topic routing changes.
#97 opened Aug 10, 2023 by humkum
3
Implement new flink-connector-rocketmq base on FLIP-27/FLIP-191
#93 opened Jul 14, 2023 by lizhimins
1
Introduce format parameter configuration to support different serialization and deserialization formats provided by Flink
#88 opened Apr 23, 2023 by hackergin
1
Introduce a separate SQL module for shading the dependencies.
#87 opened Apr 22, 2023 by hackergin
1
[BUG] topic route changed,job can't recover normally
#83 opened Jan 17, 2023 by deemogsw
6
Consumption duplication
#81 opened Dec 13, 2022 by godfather1103
4
Support rocketmq v5 client
#80 opened Dec 5, 2022 by lizhimins
@wlazjr
2
The message queue is not in assigned list bug Something isn't working
#79 opened Dec 1, 2022 by icchux
4
Some problems found by individuals during use
#78 opened Nov 30, 2022 by BukJiang
2
I have a question about DEFAULT_START_MESSAGE_OFFSET
#75 opened Nov 22, 2022 by SOD-DOB
2
[doc] Miss introduction of RocketMQSource.
#73 opened Nov 16, 2022 by GOODBOY008
1
Version below 4.6.0 does not support DefaultLitePullConsumer
#69 opened Oct 27, 2022 by deemogsw
7
ProTip! Adding no:label will show everything without a label.