Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / 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 9 months ago - 4 comments

#107 - The message queue is not in assigned list

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

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

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

#105 - 【Bug】retryTimes didn't work

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

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

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

#103 - [BUG] some bug in newSource

Issue - State: open - Opened by 844028312 10 months 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 about 1 year ago - 1 comment

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

Issue - State: closed - Opened by humkum about 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 about 1 year ago - 1 comment

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

Issue - State: open - Opened by lizhimins about 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] about 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] about 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

#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 over 1 year 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 almost 2 years ago

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

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

#75 - I have a question about DEFAULT_START_MESSAGE_OFFSET

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

#75 - I have a question about DEFAULT_START_MESSAGE_OFFSET

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

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

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

#73 - [doc] Miss introduction of RocketMQSource.

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

#73 - [doc] Miss introduction of RocketMQSource.

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

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

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

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

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

#71 - update rocketmq schema registry version

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

#71 - update rocketmq schema registry version

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

#70 - Port RocketMQSink to FLIP-143.

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

#70 - Port RocketMQSink to FLIP-143.

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

#69 - Version below 4.6.0 does not support DefaultLitePullConsumer

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

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

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

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

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

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

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

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

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

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

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

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

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

#65 - Documentation does not match reality about RocketMQSink.

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

#65 - Documentation does not match reality about RocketMQSink.

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

#64 - Support RocketMQ as LogStore for Flink Table Store

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

#64 - Support RocketMQ as LogStore for Flink Table Store

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

#63 - Support rich initialization modes of RocketMQSource

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

#63 - Support rich initialization modes of RocketMQSource

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

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

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

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

Pull Request - State: closed - Opened by deemogsw almost 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 about 2 years ago - 2 comments

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

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

#52 - support 'startMessageOffset' for RocketMQSourceFunction

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

#51 - Support 'startMessageOffset' for RocketMQSourceFunction

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

#51 - Support 'startMessageOffset' for RocketMQSourceFunction

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

#50 - Supports the 'startMessageOffset' option for RocketMQSourceFunction

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

#50 - Supports the 'startMessageOffset' option for RocketMQSourceFunction

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

#49 - [ISSUE #32] Implementation of RocketMQ Catalog

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

#49 - [ISSUE #32] Implementation of RocketMQ Catalog

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

#48 - Diff flink version support

Issue - State: open - Opened by Ink00Bamboo about 2 years ago

#48 - Diff flink version support

Issue - State: open - Opened by Ink00Bamboo about 2 years ago

#47 - [issues-44] support access control

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

#46 - [#35] Use `LitePullConsumer` model instead of default pull consumer

Pull Request - State: closed - Opened by yiduwangkai about 2 years ago - 5 comments
Labels: enhancement

#46 - [#35] Use `LitePullConsumer` model instead of default pull consumer

Pull Request - State: closed - Opened by yiduwangkai about 2 years ago - 5 comments
Labels: enhancement

#45 - [issues-44] support access control

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

#45 - [issues-44] support access control

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

#44 - Support access control

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

#44 - Support access control

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

#42 - [ISSUE #19] RocketMQSourceFunction persists offset in notifyCheckpointComplete

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

#42 - [ISSUE #19] RocketMQSourceFunction persists offset in notifyCheckpointComplete

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

#41 - WIP [ISSUE-32] Implement of Apache RocketMQ Flink Catalog.

Pull Request - State: closed - Opened by GOODBOY008 about 2 years ago
Labels: new feature