apache/rocketmq-flink issues and pull requests

#108 - roketmq can not consumer topic in cluster, it's ok in idea

Issue - State: open - Opened by luckydarnell 11 months ago - 4 comments

#107 - The message queue is not in assigned list

Issue - State: open - Opened by andyyumiao 11 months ago

#106 - [ISSUE #105] Fix sink retryTimes does not work

Pull Request - State: closed - Opened by humkum 12 months ago

#105 - 【Bug】retryTimes didn't work

Issue - State: closed - Opened by humkum 12 months ago

#104 - [ISSUE #103] Fix seek offset and deserialize bug in newSource

Pull Request - State: closed - Opened by 844028312 12 months ago - 1 comment

#103 - [BUG] some bug in newSource

Issue - State: open - Opened by 844028312 12 months ago

#102 - [ISSUE #101] Fix bug, if the optional param 'startup.offset.timestamp' is not set, a NPE will be thrown.

Pull Request - State: closed - Opened by leosanqing about 1 year ago

#101 - [BUG] If the optional param 'startup.offset.timestamp' is not set, a NullPointerException will be thrown.

Issue - State: open - Opened by leosanqing about 1 year ago

#100 - Run on k8s, it's throw RemotingTimeoutException

Issue - State: open - Opened by SOD-DOB about 1 year ago - 1 comment

#99 - why 'nameServerAddress' option unsupported?

Issue - State: open - Opened by kevinnerd over 1 year ago - 1 comment

#98 - Make job fail instead of finished when consumes exception when use l…

Pull Request - State: open - Opened by wydhcws over 1 year ago

#97 - RocketMQSourceFunction doesn't have the ability to dynamically sense topic routing changes.

Issue - State: open - Opened by humkum over 1 year ago - 2 comments

#96 - [ISSUE #95] Fix source can not consume new queue's messages when topic queue expansion

Pull Request - State: closed - Opened by humkum over 1 year ago

#95 - 【Bug】Source cannot consume new queues' messages when topic queue expanded

Issue - State: closed - Opened by humkum over 1 year ago - 1 comment

#94 - [#ISSUE 93] Implement new flink-connector-rocketmq base on FLIP-27/FLIP-191

Pull Request - State: closed - Opened by lizhimins over 1 year ago - 1 comment

#93 - Implement new flink-connector-rocketmq base on FLIP-27/FLIP-191

Issue - State: open - Opened by lizhimins over 1 year ago - 1 comment

#92 - Bump rocketmq-namesrv from 4.9.2 to 4.9.7

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies

#91 - Bump rocketmq-namesrv from 4.9.2 to 4.9.6

Pull Request - State: closed - Opened by dependabot[bot] over 1 year ago - 1 comment
Labels: dependencies

#90 - rocketmq-flink only can consume from master?

Issue - State: closed - Opened by daigoopautoy over 1 year ago

#89 - [ISSUE #88] Introduce format parameter configuration to support different serialization and deserialization formats provided by Flink

Pull Request - State: open - Opened by leosanqing over 1 year ago - 1 comment

#88 - Introduce format parameter configuration to support different serialization and deserialization formats provided by Flink

Issue - State: open - Opened by hackergin over 1 year ago - 1 comment

#87 - Introduce a separate SQL module for shading the dependencies.

Issue - State: open - Opened by hackergin over 1 year ago - 1 comment

#86 - [ISSUE #85]add the generic type into SimpleKeyValueDeserializationSchema

Pull Request - State: closed - Opened by ni-ze over 1 year ago

#85 - SimpleKeyValueDeserializationSchema is lack of generic type

Issue - State: closed - Opened by ni-ze over 1 year ago

#84 - Feature new metrics

Pull Request - State: open - Opened by ArthurWrong over 1 year ago

#83 - [BUG] topic route changed,job can't recover normally

Issue - State: open - Opened by deemogsw almost 2 years ago - 5 comments

#81 - Consumption duplication

Issue - State: open - Opened by godfather1103 almost 2 years ago - 4 comments

#81 - Consumption duplication

Issue - State: open - Opened by godfather1103 almost 2 years ago - 4 comments

#80 - Support rocketmq v5 client

Issue - State: open - Opened by lizhimins almost 2 years ago - 2 comments

#80 - Support rocketmq v5 client

Issue - State: open - Opened by lizhimins almost 2 years ago - 2 comments

#79 - The message queue is not in assigned list

Issue - State: open - Opened by icchux almost 2 years ago - 4 comments
Labels: bug

#78 - Some problems found by individuals during use

Issue - State: open - Opened by 1171971708 almost 2 years ago - 2 comments

#77 - [ISSUE #76] Fix bug when the job restore from ck

Pull Request - State: closed - Opened by deemogsw about 2 years ago

#77 - [ISSUE #76] Fix bug when the job restore from ck

Pull Request - State: closed - Opened by deemogsw about 2 years ago

#76 - [BUG] Offset will be losted when the job has restarted from checkpoint

Issue - State: closed - Opened by deemogsw about 2 years ago

#76 - [BUG] Offset will be losted when the job has restarted from checkpoint

Issue - State: closed - Opened by deemogsw about 2 years ago

#75 - I have a question about DEFAULT_START_MESSAGE_OFFSET

Issue - State: open - Opened by SOD-DOB about 2 years ago - 2 comments

#75 - I have a question about DEFAULT_START_MESSAGE_OFFSET

Issue - State: open - Opened by SOD-DOB about 2 years ago - 2 comments

#74 - 1.[fix lite pull consumer api]

Pull Request - State: open - Opened by yiduwangkai about 2 years ago - 1 comment

#73 - [doc] Miss introduction of RocketMQSource.

Issue - State: open - Opened by GOODBOY008 about 2 years ago - 1 comment

#73 - [doc] Miss introduction of RocketMQSource.

Issue - State: open - Opened by GOODBOY008 about 2 years ago - 1 comment

#72 - [ISSUE #63] Support rich initialization modes of RocketMQSource & Fix some bugs

Pull Request - State: open - Opened by deemogsw about 2 years ago - 5 comments

#72 - [ISSUE #63] Support rich initialization modes of RocketMQSource & Fix some bugs

Pull Request - State: open - Opened by deemogsw about 2 years ago - 5 comments

#71 - update rocketmq schema registry version

Pull Request - State: closed - Opened by li-xiao-shuang about 2 years ago

#71 - update rocketmq schema registry version

Pull Request - State: closed - Opened by li-xiao-shuang about 2 years ago

#70 - Port RocketMQSink to FLIP-143.

Pull Request - State: open - Opened by GOODBOY008 about 2 years ago - 1 comment

#70 - Port RocketMQSink to FLIP-143.

Pull Request - State: open - Opened by GOODBOY008 about 2 years ago - 1 comment

#69 - Version below 4.6.0 does not support DefaultLitePullConsumer

Issue - State: open - Opened by deemogsw about 2 years ago - 7 comments

#68 - [ISSUE #67] Bugfix for consume blocking

Pull Request - State: closed - Opened by deemogsw about 2 years ago - 2 comments

#68 - [ISSUE #67] Bugfix for consume blocking

Pull Request - State: closed - Opened by deemogsw about 2 years ago - 2 comments

#67 - [BUG]Consumer will be blocked after the server throws multiple exceptions.

Issue - State: closed - Opened by deemogsw about 2 years ago - 1 comment

#67 - [BUG]Consumer will be blocked after the server throws multiple exceptions.

Issue - State: closed - Opened by deemogsw about 2 years ago - 1 comment

#66 - [ISSUE #65]Update expired usage for RocketMQSink in README.md.

Pull Request - State: closed - Opened by deemogsw about 2 years ago - 1 comment

#66 - [ISSUE #65]Update expired usage for RocketMQSink in README.md.

Pull Request - State: closed - Opened by deemogsw about 2 years ago - 1 comment

#65 - Documentation does not match reality about RocketMQSink.

Issue - State: closed - Opened by GOODBOY008 about 2 years ago - 2 comments

#65 - Documentation does not match reality about RocketMQSink.

Issue - State: closed - Opened by GOODBOY008 about 2 years ago - 2 comments

#64 - Support RocketMQ as LogStore for Flink Table Store

Issue - State: open - Opened by SteNicholas about 2 years ago - 1 comment

#64 - Support RocketMQ as LogStore for Flink Table Store

Issue - State: open - Opened by SteNicholas about 2 years ago - 1 comment

#63 - Support rich initialization modes of RocketMQSource

Issue - State: open - Opened by deemogsw about 2 years ago - 2 comments

#63 - Support rich initialization modes of RocketMQSource

Issue - State: open - Opened by deemogsw about 2 years ago - 2 comments

#62 - [Feature] Support rich initialization modes of RocketMQ source

Pull Request - State: closed - Opened by deemogsw about 2 years ago - 3 comments

#62 - [Feature] Support rich initialization modes of RocketMQ source

Pull Request - State: closed - Opened by deemogsw about 2 years ago - 3 comments

#61 - [ISSUE #57] Fix some problems with the catalog

Pull Request - State: closed - Opened by li-xiao-shuang about 2 years ago - 1 comment

#61 - [ISSUE #57] Fix some problems with the catalog

Pull Request - State: closed - Opened by li-xiao-shuang about 2 years ago - 1 comment

#60 - Revert "[ISSUE #57] Fix some problems with the catalog"

Pull Request - State: closed - Opened by SteNicholas about 2 years ago

#60 - Revert "[ISSUE #57] Fix some problems with the catalog"

Pull Request - State: closed - Opened by SteNicholas about 2 years ago

#59 - Add startMode to specify offset when consumer start.Similar to kafka connector

Issue - State: closed - Opened by deemogsw about 2 years ago - 2 comments

#59 - Add startMode to specify offset when consumer start.Similar to kafka connector

Issue - State: closed - Opened by deemogsw about 2 years ago - 2 comments

#58 - [ISSUE #57] Fix some problems with the catalog

Pull Request - State: closed - Opened by li-xiao-shuang about 2 years ago

#58 - [ISSUE #57] Fix some problems with the catalog

Pull Request - State: closed - Opened by li-xiao-shuang about 2 years ago

#57 - Fix some problems with the catalog

Issue - State: closed - Opened by li-xiao-shuang about 2 years ago

#57 - Fix some problems with the catalog

Issue - State: closed - Opened by li-xiao-shuang about 2 years ago

#56 - Port RocketMQSink to FLIP-143

Issue - State: open - Opened by GOODBOY008 about 2 years ago - 1 comment

#56 - Port RocketMQSink to FLIP-143

Issue - State: open - Opened by GOODBOY008 about 2 years ago - 1 comment

#55 - [Polish] Move example code to somewhere?

Issue - State: open - Opened by GOODBOY008 about 2 years ago - 1 comment
Labels: disscuss

#55 - [Polish] Move example code to somewhere?

Issue - State: open - Opened by GOODBOY008 about 2 years ago - 1 comment
Labels: disscuss

#54 - [ISSUE #12] Support scan startup mode

Pull Request - State: closed - Opened by liyubin117 about 2 years ago

#53 - org.apache.rocketmq:schema-registry-client non-existent

Issue - State: open - Opened by chaotianque over 2 years ago - 2 comments