duhenglucky commented on issue #3275:
URL: https://github.com/apache/rocketmq/issues/3275#issuecomment-901651454
> > > https://github.com/apache/rocketmq/blob/master/docs/cn/operation.md
> > >
如上启动命令是在单个NameServer情况下使用的。对于多个NameServer的集群，Broker启动命令中-n后面的地址列表用分号隔开即可，例如
192.168.1.1:9876;1
lgd8069465 commented on issue #3275:
URL: https://github.com/apache/rocketmq/issues/3275#issuecomment-901650180
> > https://github.com/apache/rocketmq/blob/master/docs/cn/operation.md
> >
如上启动命令是在单个NameServer情况下使用的。对于多个NameServer的集群，Broker启动命令中-n后面的地址列表用分号隔开即可，例如
192.168.1.1:9876;192.16
+1,
checked:
[OK] Source code artifacts have correct names matching the current release.
[OK] Hash and Tag in GitHub repo is matching the current artifacts.
[OK] The code can be built success in the source package.
[OK] Start nameserver and broker according to the quick-start
[OK] Run clusterL
vongosling closed issue #775:
URL: https://github.com/apache/rocketmq-externals/issues/775
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-uns
SteNicholas commented on issue #775:
URL:
https://github.com/apache/rocketmq-externals/issues/775#issuecomment-901606776
> Hi guys,
> I am using flink version 1.1.2, which is lower than master version 1.1.3.
So I face NoclassFoundError. Is some milestone support flink 1.1.2 ?
>
>
vongosling commented on issue #780:
URL:
https://github.com/apache/rocketmq-externals/issues/780#issuecomment-901602487
We could link the issue with pr in case of forgetting to close the related
issues.
--
This is an automated message from the Apache Git Service.
To respond to the messa
vongosling closed issue #780:
URL: https://github.com/apache/rocketmq-externals/issues/780
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-uns
vongosling commented on pull request #6:
URL: https://github.com/apache/rocketmq-dashboard/pull/6#issuecomment-901601418
@zhangjidi2016 there are many places waiting to be clarified. BTW, do we
have a better way to support here. do not link permission to URL directly?
--
This is an autom
vongosling closed issue #5:
URL: https://github.com/apache/rocketmq-dashboard/issues/5
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubsc
vongosling merged pull request #7:
URL: https://github.com/apache/rocketmq-dashboard/pull/7
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-un
vongosling commented on issue #9:
URL:
https://github.com/apache/rocketmq-dashboard/issues/9#issuecomment-901599935
@francisoliverlee
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specif
vongosling closed issue #9:
URL: https://github.com/apache/rocketmq-dashboard/issues/9
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubsc
duhenglucky commented on issue #786:
URL:
https://github.com/apache/rocketmq-externals/issues/786#issuecomment-901596119
merged
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
duhenglucky closed issue #786:
URL: https://github.com/apache/rocketmq-externals/issues/786
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-un
duhenglucky merged pull request #790:
URL: https://github.com/apache/rocketmq-externals/pull/790
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
fwhezfwhez commented on issue #9:
URL:
https://github.com/apache/rocketmq-dashboard/issues/9#issuecomment-901587942
3q done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
SteNicholas opened a new pull request #790:
URL: https://github.com/apache/rocketmq-externals/pull/790
## What is the purpose of the change
`RocketMQSourceFunction` should support the close of `ExecutorService` and
`ScheduledExecutorService` which should be closed when the `SourceOpe
duhenglucky closed issue #788:
URL: https://github.com/apache/rocketmq-externals/issues/788
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-un
SteNicholas commented on issue #788:
URL:
https://github.com/apache/rocketmq-externals/issues/788#issuecomment-901582108
@ni-ze , `RocketMQSourceFunction` starts the `DefaultMQPullConsumer` in the
`open()` method and closes the `DefaultMQPullConsumer` in the `close` method.
This behavior
codecov-commenter edited a comment on pull request #3256:
URL: https://github.com/apache/rocketmq/pull/3256#issuecomment-901581106
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/3256?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_
coveralls edited a comment on pull request #3256:
URL: https://github.com/apache/rocketmq/pull/3256#issuecomment-897788933
[](https://coveralls.io/builds/42256829)
Coverage increased (+0.2%) to 54.145% when pulling
**
codecov-commenter commented on pull request #3256:
URL: https://github.com/apache/rocketmq/pull/3256#issuecomment-901581106
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/3256?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Th
Build Update for apache/rocketmq-externals
-
Build: #171
Status: Fixed
Duration: 2 mins and 17 secs
Commit: ea2bfd4 (master)
Author: SteNicholas
Message: [#780] Support the RocketMQ TableSink based on the legacy Sink
implementation (#781)
View the changeset:
duhenglucky commented on issue #3275:
URL: https://github.com/apache/rocketmq/issues/3275#issuecomment-901574868
> https://github.com/apache/rocketmq/blob/master/docs/cn/operation.md
>
如上启动命令是在单个NameServer情况下使用的。对于多个NameServer的集群，Broker启动命令中-n后面的地址列表用分号隔开即可，例如
192.168.1.1:9876;192.161.2
duhenglucky closed issue #3275:
URL: https://github.com/apache/rocketmq/issues/3275
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-unsubscr..
duhenglucky closed issue #785:
URL: https://github.com/apache/rocketmq-externals/issues/785
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-un
SteNicholas commented on issue #785:
URL:
https://github.com/apache/rocketmq-externals/issues/785#issuecomment-901564869
@ni-ze , thanks for the problem reportor to the Flink maven dependencies. I
have set the scope of Flink dependencies to `provided`.
--
This is an automated message fr
AaronW-BE opened a new issue #3276:
URL: https://github.com/apache/rocketmq/issues/3276
The cmd batch file ignored java default install directory like `program
files`, it's will cause cannot start mq
--
This is an automated message from the Apache Git Service.
To respond to the message,
lgd8069465 opened a new issue #3275:
URL: https://github.com/apache/rocketmq/issues/3275
https://github.com/apache/rocketmq/blob/master/docs/cn/operation.md
如上启动命令是在单个NameServer情况下使用的。对于多个NameServer的集群，Broker启动命令中-n后面的地址列表用分号隔开即可，例如
192.168.1.1:9876;192.161.2:9876。
--
This is an autom
duhenglucky closed issue #787:
URL: https://github.com/apache/rocketmq-externals/issues/787
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: dev-un
duhenglucky commented on issue #787:
URL:
https://github.com/apache/rocketmq-externals/issues/787#issuecomment-901524283
merged
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comm
duhenglucky merged pull request #781:
URL: https://github.com/apache/rocketmq-externals/pull/781
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
schnell18 commented on a change in pull request #3256:
URL: https://github.com/apache/rocketmq/pull/3256#discussion_r691685939
##
File path: store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
##
@@ -34,6 +37,7 @@
private static final InternalLogger LOG_ERRO
caigy commented on issue #3264:
URL: https://github.com/apache/rocketmq/issues/3264#issuecomment-901070559
@zhaohai1299002788 Could you submit a PR to fix it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
ni-ze commented on pull request #779:
URL:
https://github.com/apache/rocketmq-externals/pull/779#issuecomment-900797723
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To
coveralls edited a comment on pull request #3256:
URL: https://github.com/apache/rocketmq/pull/3256#issuecomment-897788933
[](https://coveralls.io/builds/42223255)
Coverage increased (+0.3%) to 54.219% when pulling
**
ni-ze edited a comment on pull request #779:
URL:
https://github.com/apache/rocketmq-externals/pull/779#issuecomment-900797723
@SteNicholas Thread Pool do not close when job finish
https://github.com/apache/rocketmq-externals/issues/786#issue-973254402
--
This is an automated mes
liuruinl commented on issue #3265:
URL: https://github.com/apache/rocketmq/issues/3265#issuecomment-900946121
Thanks for Good job ! But in the other hand, it seems like this is not a
MQ's responsibility to handle our deployment requirements, keep simple and
clean.
--
This is an automat
duhenglucky merged pull request #703:
URL: https://github.com/apache/rocketmq-externals/pull/703
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
vongosling commented on pull request #779:
URL:
https://github.com/apache/rocketmq-externals/pull/779#issuecomment-900869821
@SteNicholas I see the status of our flink integration, there is still
improvement to polish before we call for gruduation. #787 (comment), do we have
a plan to sup
zhangjidi2016 commented on a change in pull request #7:
URL: https://github.com/apache/rocketmq-dashboard/pull/7#discussion_r690842785
##
File path:
src/main/java/org/apache/rocketmq/dashboard/controller/LoginController.java
##
@@ -65,10 +66,10 @@ public Object check(HttpServl
zxcvbnm3057 commented on issue #3272:
URL: https://github.com/apache/rocketmq/issues/3272#issuecomment-900503281
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscr
drgnchan commented on a change in pull request #3256:
URL: https://github.com/apache/rocketmq/pull/3256#discussion_r690928372
##
File path: store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
##
@@ -34,6 +37,7 @@
private static final InternalLogger LOG_ERROR
StyleTang commented on issue #9:
URL:
https://github.com/apache/rocketmq-dashboard/issues/9#issuecomment-901185710
Could you try
```
docker pull apacherocketmq/rocketmq-console:2.0.0
```
We can find the tags
[here](https://hub.docker.com/r/apacherocketmq/rocketmq-console/tags?p
SteNicholas commented on pull request #781:
URL:
https://github.com/apache/rocketmq-externals/pull/781#issuecomment-900876590
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment
zhaohai1299002788 commented on issue #3264:
URL: https://github.com/apache/rocketmq/issues/3264#issuecomment-900744534
newFixedThreadPool is a fixed number of threads, using an infinite queue.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
francisoliverlee commented on issue #3267:
URL: https://github.com/apache/rocketmq/issues/3267#issuecomment-900440037
same scenario we met. we made a Enhance-DefaultPushConsumer, doing your
filter logic in it.
--
This is an automated message from the Apache Git Service.
To respond to th
ni-ze commented on pull request #781:
URL:
https://github.com/apache/rocketmq-externals/pull/781#issuecomment-900895647
I can help make a review, but also need approve from write permission.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
duhenglucky merged pull request #712:
URL: https://github.com/apache/rocketmq-client-go/pull/712
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
SteNicholas edited a comment on pull request #779:
URL:
https://github.com/apache/rocketmq-externals/pull/779#issuecomment-900766859
> @duhenglucky @RongtongJin @SteNicholas This connector may donate to flink
like this, [apache/flink#15304](https://github.com/apache/flink/pull/15304). I
w
SteNicholas commented on pull request #779:
URL:
https://github.com/apache/rocketmq-externals/pull/779#issuecomment-900766859
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment
StyleTang commented on a change in pull request #7:
URL: https://github.com/apache/rocketmq-dashboard/pull/7#discussion_r690492743
##
File path: src/main/resources/static/src/ops.js
##
@@ -15,10 +15,12 @@
* limitations under the License.
*/
-app.controller('opsController'
vongosling commented on a change in pull request #6:
URL: https://github.com/apache/rocketmq-dashboard/pull/6#discussion_r690844961
##
File path: doc/1_0_0/UserGuide_CN.md
##
@@ -112,4 +112,35 @@ admin=admin,1
user1=user1
user2=user2
```
-* 3. 启动控制台则开启了登录功能
\ No newline at e
makabakaboom commented on issue #3265:
URL: https://github.com/apache/rocketmq/issues/3265#issuecomment-900778603
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubsc
duhenglucky merged pull request #779:
URL: https://github.com/apache/rocketmq-externals/pull/779
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
duhenglucky commented on a change in pull request #779:
URL: https://github.com/apache/rocketmq-externals/pull/779#discussion_r690837086
##
File path:
rocketmq-flink/src/main/java/org/apache/rocketmq/flink/legacy/common/serialization/RowKeyValueDeserializationSchema.java
##
@@
francisoliverlee commented on issue #3265:
URL: https://github.com/apache/rocketmq/issues/3265#issuecomment-900766282
suppose there are 10 producer instances and 10 consumer instances, if we
need to do gray release, how about do-gray-deployment to producer instance 1
and consumer instance
francisoliverlee commented on issue #3272:
URL: https://github.com/apache/rocketmq/issues/3272#issuecomment-900426274
### request-reply message can be right for you .
- demo sync producer :
https://github.com/apache/rocketmq/blob/master/example/src/main/java/org/apache/rocketmq/exam
duhenglucky merged pull request #698:
URL: https://github.com/apache/rocketmq-externals/pull/698
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
ni-ze commented on a change in pull request #779:
URL: https://github.com/apache/rocketmq-externals/pull/779#discussion_r690837199
##
File path: rocketmq-flink/pom.xml
##
@@ -34,7 +34,7 @@
1.8
1.8
4.7.1
-1.13.0
+1.13.1
Review comment:
zhangjidi2016 commented on a change in pull request #6:
URL: https://github.com/apache/rocketmq-dashboard/pull/6#discussion_r690827669
##
File path:
src/main/java/org/apache/rocketmq/dashboard/service/impl/PermissionServiceImpl.java
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the
superhx commented on a change in pull request #712:
URL: https://github.com/apache/rocketmq-client-go/pull/712#discussion_r690866875
##
File path: consumer/push_consumer.go
##
@@ -119,6 +119,9 @@ func NewPushConsumer(opts ...Option) (*pushConsumer, error)
{
p.interce
vongosling commented on a change in pull request #779:
URL: https://github.com/apache/rocketmq-externals/pull/779#discussion_r690949600
##
File path: rocketmq-flink/pom.xml
##
@@ -45,11 +45,13 @@
org.apache.flink
flink-java
${flink.version
ShannonDing merged pull request #714:
URL: https://github.com/apache/rocketmq-client-go/pull/714
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
duhenglucky commented on pull request #779:
URL:
https://github.com/apache/rocketmq-externals/pull/779#issuecomment-900745867
> @duhenglucky @RongtongJin @SteNicholas This connector may donate to flink
like this, [apache/flink#15304](https://github.com/apache/flink/pull/15304). I
would li
ni-ze commented on a change in pull request #781:
URL: https://github.com/apache/rocketmq-externals/pull/781#discussion_r691140471
##
File path:
rocketmq-flink/src/main/java/org/apache/rocketmq/flink/sink/table/RocketMQDynamicTableSink.java
##
@@ -0,0 +1,257 @@
+/*
+ * License
francisoliverlee commented on issue #3271:
URL: https://github.com/apache/rocketmq/issues/3271#issuecomment-900435728
do you have a demo to re-produce it ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above
zhangguobin-xiyue commented on issue #1:
URL:
https://github.com/apache/rocketmq-dashboard/issues/1#issuecomment-901024195
Organization: Mukun Technology
Location: Anhui Hefei
Contact: 61527...@qq.com
Version: v2.0.0
Status: stage
Expectations(optional):
--
This is an auto
SteNicholas removed a comment on pull request #781:
URL:
https://github.com/apache/rocketmq-externals/pull/781#issuecomment-900876590
@vongosling @duhenglucky , could you help to review the RocketMQ TableSink
based on the legacy Sink implementation?
--
This is an automated message from
StyleTang commented on issue #9:
URL:
https://github.com/apache/rocketmq-dashboard/issues/9#issuecomment-901185710
Could you try
```
docker pull apacherocketmq/rocketmq-console:2.0.0
```
We can find the tags
[here](https://hub.docker.com/r/apacherocketmq/rocketmq-console/tags?p
caigy commented on issue #3264:
URL: https://github.com/apache/rocketmq/issues/3264#issuecomment-901070559
@zhaohai1299002788 Could you submit a PR to fix it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
+1
I checked:
[OK] Run clusterList command to see if the version is correct
[OK] Build the source, start nameserver and broker according to the
quick-start
[OK] All unit tests of the current version pass
-- --
??:
+1,I checked.
原始信息 发件人： 胡 宗棠 日期: 2021/8/18 14:25
(GMT+08:00) 收件人： dev@rocketmq.apache.org 主题： [VOTE]:Release Apache RocketMQ
4.9.1 RC1. Hello RocketMQ Community,This is the vote for 4.9.1 of Apache
RocketMQ.This release is to improve some features and issues for apache
rocke
ni-ze commented on a change in pull request #781:
URL: https://github.com/apache/rocketmq-externals/pull/781#discussion_r691140471
##
File path:
rocketmq-flink/src/main/java/org/apache/rocketmq/flink/sink/table/RocketMQDynamicTableSink.java
##
@@ -0,0 +1,257 @@
+/*
+ * License
+1
I checked:
[OK] Hash and Tag in GitHub repo are matching the current artifacts.
[OK] The code can be built success in the source package.
[OK] Run clusterList command to see if the version is correct
[OK] Quickstart works well
倪泽 于2021年8月18日周三 下午4:43写道：
> +1
>
> My check list is as fello
zhangguobin-xiyue commented on issue #1:
URL:
https://github.com/apache/rocketmq-dashboard/issues/1#issuecomment-901024195
Organization: Mukun Technology
Location: Anhui Hefei
Contact: 61527...@qq.com
Version: v2.0.0
Status: stage
Expectations(optional):
--
This is an auto
fwhezfwhez opened a new issue #9:
URL: https://github.com/apache/rocketmq-dashboard/issues/9
daemon.json
{
"registry-mirrors": ["https://registry.docker-cn.com";]
}
Which mirror provides acessible image
--
This is an automated message from the Apache Git Service.
To r
makabakaboom commented on issue #3265:
URL: https://github.com/apache/rocketmq/issues/3265#issuecomment-900970870
> Thanks for Good job ! But in the other hand, it seems like this is not a
MQ's responsibility to handle our deployment requirements, keep simple and
clean.
OK，不过在实际应用过程
Build Update for apache/rocketmq-externals
-
Build: #166
Status: Still Failing
Duration: 2 mins and 38 secs
Commit: f93626e (master)
Author: SteNicholas
Message: [#715] Support the RocketMQ TableSource based on the legacy Source
implementation (#779)
View the
liuruinl commented on issue #3265:
URL: https://github.com/apache/rocketmq/issues/3265#issuecomment-900946121
Thanks for Good job ! But in the other hand, it seems like this is not a
MQ's responsibility to handle our deployment requirements, keep simple and
clean.
--
This is an automat
+1
My check list is as fellow:
artifacts package is the same as current release version.
source package can build success
nameserver and broker can start up
clusterlist command can success and version is correct.
use tools to produce and consume message success.
周波 于2021年8月18日周三 下午4:26写道：
>
+1
I checked:
[OK] Source code artifacts have correct names matching the current release.
[OK] Hash and Tag in GitHub repo is matching the current artifacts.
[OK] The code can be built success in the source package.
[OK] Run clusterList command to see if the version is correct
[OK] Build the
I vote +1 (non-binding)
I checked the following:
- Licence by Apache RAT
- Hashes of binary and source files are correct
- Signatures of binary and source files are correct
- Source code can be built successfully and all unit tests are passed locally
- Nameserver and Broker can be run succe
ni-ze commented on pull request #781:
URL:
https://github.com/apache/rocketmq-externals/pull/781#issuecomment-900895647
I can help make a review, but also need approve from write permission.
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
505703441 opened a new issue #789:
URL: https://github.com/apache/rocketmq-externals/issues/789
#704
rocketmq-client:4.8.0
org.apache.rocketmq.client.impl.MQClientManager.getOrCreateMQClientInstance()
same instanceName use same instance->the same TCPLink
--
This is a
+1 (non-binding)
checked:
- All links are valid.
- All ASF files have ASF headers
use: mvn clean apache-rat:check
- Can compile from source
use: mvn clean install -DskipTests
mvn -Prelease-all -DskipTests clean package -U
- Start nameserver and broker according to the quick-start
Ro
SteNicholas commented on pull request #781:
URL:
https://github.com/apache/rocketmq-externals/pull/781#issuecomment-900881282
@vongosling @duhenglucky , could you help to review the RocketMQ TableSink
based on the legacy Sink implementation?
--
This is an automated message from the Apa
SteNicholas removed a comment on pull request #781:
URL:
https://github.com/apache/rocketmq-externals/pull/781#issuecomment-900876590
@vongosling @duhenglucky , could you help to review the RocketMQ TableSink
based on the legacy Sink implementation?
--
This is an automated message from
zxcvbnm3057 commented on issue #3272:
URL: https://github.com/apache/rocketmq/issues/3272#issuecomment-900877543
Another problem is that `MessageUtil.createReplyMessage` needs to be called
to reply in another thread, so it must have the reference of the original
request message. If the rep
SteNicholas commented on pull request #781:
URL:
https://github.com/apache/rocketmq-externals/pull/781#issuecomment-900876590
@vongosling @duhenglucky , could you help to review the RocketMQ TableSink
based on the legacy Sink implementation?
--
This is an automated message from the Apac
duhenglucky merged pull request #779:
URL: https://github.com/apache/rocketmq-externals/pull/779
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: d
+1
周波 于2021年8月18日周三 下午2:56写道：
> +1
>
> 胡 宗棠 于2021年8月18日周三 下午2:25写道：
>
> > Hello RocketMQ Community,
> >
> >
> > This is the vote for 4.9.1 of Apache RocketMQ.
> >
> >
> > This release is to improve some features and issues for apache
> > rocketmq,such as improving rocketmq's remarkable throughp
vongosling commented on pull request #779:
URL:
https://github.com/apache/rocketmq-externals/pull/779#issuecomment-900869821
@SteNicholas I see the status of our flink integration, there is still
improvement to polish before we call for gruduation. #787 (comment), do we have
a plan to sup
93 matches
Mail list logo
