SteNicholas opened a new issue #3:
URL: https://github.com/apache/rocketmq-flink/issues/3
## The purpose of this issue
The `Catalog` interface is responsible for reading and writing metadata such
as database/table/views/UDFs from a registered catalog in the Flink.
RocketMQ-Flink sh
odbozhou commented on pull request #795:
URL:
https://github.com/apache/rocketmq-externals/pull/795#issuecomment-908271159
please summit a issue first .
--
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 t
odbozhou commented on pull request #797:
URL:
https://github.com/apache/rocketmq-externals/pull/797#issuecomment-908271385
please summit a issue first .
--
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 t
Git-Yang opened a new issue #68:
URL: https://github.com/apache/rocketmq-exporter/issues/68
- Rely on RocketMQ service to support queue-level statistics for delayed
messages.
https://github.com/apache/rocketmq/issues/3296
**Background**
In order to increase the ability to monitor d
StyleTang commented on pull request #6:
URL: https://github.com/apache/rocketmq-dashboard/pull/6#issuecomment-908279083
@zhangjidi2016
Do you have any further updates for this PR.
If no further updates, since the feature works well, I'm OK to merge it and
we can refactor it in the fu
zhangjidi2016 commented on pull request #6:
URL: https://github.com/apache/rocketmq-dashboard/pull/6#issuecomment-908302947
> @zhangjidi2016
> Do you have any further updates for this PR.
> If no further updates, since the feature works well, I'm OK to merge it
and we can refactor it
Silverados opened a new pull request #3303:
URL: https://github.com/apache/rocketmq/pull/3303
fix message.getBody().length() --> message.getBody().length
**Make sure set the target branch to `develop`**
## What is the purpose of the change
fix sample mistake~
Silverados opened a new pull request #3304:
URL: https://github.com/apache/rocketmq/pull/3304
message.getBody() return byte[], so change to length.
Trivial changes~
**Make sure set the target branch to `develop`**
## What is the purpose of the change
## Brief
yuanxiaodong opened a new pull request #42:
URL: https://github.com/apache/rocketmq-streams/pull/42
finish single split test for window exactly once
--
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
codecov-commenter commented on pull request #3304:
URL: https://github.com/apache/rocketmq/pull/3304#issuecomment-908364127
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/3304?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Th
panzhi33 commented on issue #3301:
URL: https://github.com/apache/rocketmq/issues/3301#issuecomment-908438693
只有indexFile写满了，才会强制刷盘。其他时候，都是等待操作系统来刷的。commitlog如果不是SYNC_FLUSH，也是等待操作系统来刷的。indexfile文件就算丢失了，broker也可以通过commitlog来重建的。
--
This is an automated message from the Apache Git Service.
francisoliverlee commented on issue #41:
URL: https://github.com/apache/rocketmq-streams/issues/41#issuecomment-908515210
some examples here:
https://github.com/apache/rocketmq-streams/tree/main/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples
--
This is an au
SpriderMan commented on issue #3301:
URL: https://github.com/apache/rocketmq/issues/3301#issuecomment-908815810
>
只有indexFile写满了，才会强制刷盘。其他时候，都是等待操作系统来刷的。commitlog如果不是SYNC_FLUSH，也是等待操作系统来刷的。indexfile文件就算丢失了，broker也可以通过commitlog来重建的。
好的 谢谢
--
This is an automated message from the Ap
SpriderMan closed issue #3301:
URL: https://github.com/apache/rocketmq/issues/3301
--
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...
lizhimins commented on issue #3265:
URL: https://github.com/apache/rocketmq/issues/3265#issuecomment-908859081
原生灰度能力确实很有吸引力，实现方式是特殊的负载均衡策略还是不同的订阅方式还需要考虑下
--
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
Git-Yang opened a new issue #3306:
URL: https://github.com/apache/rocketmq/issues/3306
1. Please describe the feature you are requesting.
- Implement the selection of Queue according to the machine room to send
messages.
2. Provide any additional detail on your proposed use ca
Git-Yang opened a new pull request #3307:
URL: https://github.com/apache/rocketmq/pull/3307
## What is the purpose of the change
#3306
## Brief changelog
- Assign the expected message to be written to the computer room in
consumeridcs, and confirm the machine room to w
liuliuzo commented on pull request #347:
URL: https://github.com/apache/rocketmq-spring/pull/347#issuecomment-908941905
@zongtanghu conflicts has been solved thx for review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Johnnyhooyo opened a new issue #802:
URL: https://github.com/apache/rocketmq-externals/issues/802
i have a question:
```
HashMap configMap = new HashMap<>();
configMap.put(RocketMQConfig.NAME_SERVER_ADDR, serviceUrl);
JavaInputDStream stream =
RocketMqUti
lizhiboo opened a new issue #803:
URL: https://github.com/apache/rocketmq-externals/issues/803
line 87 in ConnectUtil
```java
public static DefaultMQProducer initDefaultMQProducer(ConnectConfig
connectConfig) {
DefaultMQProducer producer = new DefaultMQProducer();
lwclover opened a new issue #3308:
URL: https://github.com/apache/rocketmq/issues/3308
最近使用RocketMQ pull API做了消息同步的功能，也就是将指定topic消息从一个集群同步到另外一个集群。
考虑到性能因素，第一印象就是使用pull API。
这个功能在编写的过程中，发现simple里的demo并不适用于生产环境。
使用PULL API应该考虑一下几点：
1.消息队列的负载均衡
2.消费进度的存储
3.PullResult的处理
4.性
coveralls commented on pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302#issuecomment-909028328
[](https://coveralls.io/builds/42495842)
Coverage decreased (-0.02%) to 54.207% when pulling
**f4d2c6
lwclover commented on issue #3308:
URL: https://github.com/apache/rocketmq/issues/3308#issuecomment-909028278
pr #3295
--
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
lwclover commented on pull request #3295:
URL: https://github.com/apache/rocketmq/pull/3295#issuecomment-909027145
fix #3308
--
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
lwclover edited a comment on issue #3308:
URL: https://github.com/apache/rocketmq/issues/3308#issuecomment-909028278
#3295
--
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.
coveralls edited a comment on pull request #3224:
URL: https://github.com/apache/rocketmq/pull/3224#issuecomment-893982658
[](https://coveralls.io/builds/42495772)
Coverage decreased (-0.009%) to 54.217% when pulling
tankcong opened a new issue #115:
URL: https://github.com/apache/rocketmq-client-python/issues/115
**BUG REPORT**
1. Please describe the issue you observed:
running samples/producer.py with error:
> Traceback (most recent call last):
File "producer.py", line
coveralls edited a comment on pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302#issuecomment-909028328
[](https://coveralls.io/builds/42496221)
Coverage increased (+0.03%) to 54.255% when pulling
*
aaron-ai opened a new issue #3309:
URL: https://github.com/apache/rocketmq/issues/3309
Since openCensus and openTracing has been merged into openTelemetry, and
kafka/rabbitMQ has added their custom span attributes to openTelemetry official
specification.
Base on the fact above, I th
zhuozl opened a new issue #804:
URL: https://github.com/apache/rocketmq-externals/issues/804
是否有 rocketmq-replicator更详细的部署文档,根据官方文档部署不生效.
1. 创建俩套rocketmq 版本V4.5.1
2. 源mq 创建topic如下
connector-cluster-topic
connector-config-topic
connector-offset-to
coveralls edited a comment on pull request #3149:
URL: https://github.com/apache/rocketmq/pull/3149#issuecomment-880750487
[](https://coveralls.io/builds/42508382)
Coverage increased (+0.05%) to 54.226% when pulling
*
StyleTang commented on a change in pull request #14:
URL: https://github.com/apache/rocketmq-dashboard/pull/14#discussion_r699301209
##
File path: LICENSE
##
@@ -413,17 +391,13 @@ Font-Awesome
--
https://github.com/FortAwesome/Font-Awesome
-License
-
-Th
shendongsd commented on pull request #75:
URL: https://github.com/apache/rocketmq-operator/pull/75#issuecomment-909220119
> 1. I think abbreviations like `reqDurSchIgnDurExe` are not no clear,
especially for new beginners of K8s. For example, 'req' is short for 'request'
in most cases othe
StyleTang commented on pull request #6:
URL: https://github.com/apache/rocketmq-dashboard/pull/6#issuecomment-909225934
@zhangjidi2016
This branch has conflicts with master, could you resolve the conflicts.
Thanks.
--
This is an automated message from the Apache Git Service.
To res
coveralls commented on pull request #3304:
URL: https://github.com/apache/rocketmq/pull/3304#issuecomment-909225918
[](https://coveralls.io/builds/42509473)
Coverage decreased (-0.07%) to 54.154% when pulling
**4bfa00
lizhanhui commented on issue #3309:
URL: https://github.com/apache/rocketmq/issues/3309#issuecomment-909227048
Good idea. Excited to see RocketMQ with tracing capabiblity.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
panzhi33 commented on issue #3301:
URL: https://github.com/apache/rocketmq/issues/3301#issuecomment-908438693
只有indexFile写满了，才会强制刷盘。其他时候，都是等待操作系统来刷的。commitlog如果不是SYNC_FLUSH，也是等待操作系统来刷的。indexfile文件就算丢失了，broker也可以通过commitlog来重建的。
--
This is an automated message from the Apache Git Service.
SpriderMan commented on issue #3301:
URL: https://github.com/apache/rocketmq/issues/3301#issuecomment-908815810
>
只有indexFile写满了，才会强制刷盘。其他时候，都是等待操作系统来刷的。commitlog如果不是SYNC_FLUSH，也是等待操作系统来刷的。indexfile文件就算丢失了，broker也可以通过commitlog来重建的。
好的 谢谢
--
This is an automated message from the Ap
coveralls commented on pull request #3304:
URL: https://github.com/apache/rocketmq/pull/3304#issuecomment-909225918
[](https://coveralls.io/builds/42509473)
Coverage decreased (-0.07%) to 54.154% when pulling
**4bfa00
lwclover commented on pull request #3295:
URL: https://github.com/apache/rocketmq/pull/3295#issuecomment-909027145
fix #3308
--
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 #14:
URL: https://github.com/apache/rocketmq-dashboard/pull/14#discussion_r699301209
##
File path: LICENSE
##
@@ -413,17 +391,13 @@ Font-Awesome
--
https://github.com/FortAwesome/Font-Awesome
-License
-
-Th
liuliuzo commented on pull request #347:
URL: https://github.com/apache/rocketmq-spring/pull/347#issuecomment-908941905
@zongtanghu conflicts has been solved thx for review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
SpriderMan closed issue #3301:
URL: https://github.com/apache/rocketmq/issues/3301
--
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...
coveralls commented on pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302#issuecomment-909028328
[](https://coveralls.io/builds/42495842)
Coverage decreased (-0.02%) to 54.207% when pulling
**f4d2c6
francisoliverlee commented on issue #41:
URL: https://github.com/apache/rocketmq-streams/issues/41#issuecomment-908515210
some examples here:
https://github.com/apache/rocketmq-streams/tree/main/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples
--
This is an au
coveralls edited a comment on pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302#issuecomment-909028328
[](https://coveralls.io/builds/42496221)
Coverage increased (+0.03%) to 54.255% when pulling
*
codecov-commenter commented on pull request #3304:
URL: https://github.com/apache/rocketmq/pull/3304#issuecomment-908364127
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/3304?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=Th
lwclover commented on issue #3308:
URL: https://github.com/apache/rocketmq/issues/3308#issuecomment-909028278
pr #3295
--
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
StyleTang commented on pull request #6:
URL: https://github.com/apache/rocketmq-dashboard/pull/6#issuecomment-909225934
@zhangjidi2016
This branch has conflicts with master, could you resolve the conflicts.
Thanks.
--
This is an automated message from the Apache Git Service.
To res
lizhimins commented on issue #3265:
URL: https://github.com/apache/rocketmq/issues/3265#issuecomment-908859081
原生灰度能力确实很有吸引力，实现方式是特殊的负载均衡策略还是不同的订阅方式还需要考虑下
--
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
lwclover edited a comment on issue #3308:
URL: https://github.com/apache/rocketmq/issues/3308#issuecomment-909028278
#3295
--
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.
shendongsd commented on pull request #75:
URL: https://github.com/apache/rocketmq-operator/pull/75#issuecomment-909220119
> 1. I think abbreviations like `reqDurSchIgnDurExe` are not no clear,
especially for new beginners of K8s. For example, 'req' is short for 'request'
in most cases othe
coveralls edited a comment on pull request #3149:
URL: https://github.com/apache/rocketmq/pull/3149#issuecomment-880750487
[](https://coveralls.io/builds/42508382)
Coverage increased (+0.05%) to 54.226% when pulling
*
coveralls edited a comment on pull request #3224:
URL: https://github.com/apache/rocketmq/pull/3224#issuecomment-893982658
[](https://coveralls.io/builds/42495772)
Coverage decreased (-0.009%) to 54.217% when pulling
lizhanhui commented on issue #3309:
URL: https://github.com/apache/rocketmq/issues/3309#issuecomment-909227048
Good idea. Excited to see RocketMQ with tracing capabiblity.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
coveralls commented on pull request #3305:
URL: https://github.com/apache/rocketmq/pull/3305#issuecomment-909671287
[](https://coveralls.io/builds/42534381)
Coverage increased (+0.05%) to 54.143% when pulling
**feb267
coveralls commented on pull request #3307:
URL: https://github.com/apache/rocketmq/pull/3307#issuecomment-909685047
[](https://coveralls.io/builds/42535310)
Coverage increased (+0.02%) to 54.245% when pulling
**bf69b1
coveralls edited a comment on pull request #3149:
URL: https://github.com/apache/rocketmq/pull/3149#issuecomment-880750487
[](https://coveralls.io/builds/42548184)
Coverage increased (+0.06%) to 54.231% when pulling
*
odbozhou merged pull request #795:
URL: https://github.com/apache/rocketmq-externals/pull/795
--
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-
odbozhou commented on issue #796:
URL:
https://github.com/apache/rocketmq-externals/issues/796#issuecomment-909803243
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 comment
odbozhou closed issue #796:
URL: https://github.com/apache/rocketmq-externals/issues/796
--
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-unsub
odbozhou merged pull request #797:
URL: https://github.com/apache/rocketmq-externals/pull/797
--
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-
odbozhou closed issue #798:
URL: https://github.com/apache/rocketmq-externals/issues/798
--
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-unsub
odbozhou commented on issue #798:
URL:
https://github.com/apache/rocketmq-externals/issues/798#issuecomment-909804239
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 comment
vongosling closed issue #13:
URL: https://github.com/apache/rocketmq-dashboard/issues/13
--
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-unsub
vongosling merged pull request #14:
URL: https://github.com/apache/rocketmq-dashboard/pull/14
--
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-
odbozhou commented on issue #803:
URL:
https://github.com/apache/rocketmq-externals/issues/803#issuecomment-909821853
In the current design, different workerTasks handle different topics. One
workerTask corresponds to one pullConsumer, which improves concurrency to a
certain extent, so th
yuanxiaodong opened a new pull request #43:
URL: https://github.com/apache/rocketmq-streams/pull/43
test window exactly once success and fixed bugs
--
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 t
lizhiboo commented on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909823095
> 是否有 rocketmq-replicator更详细的部署文档,根据官方文档部署不生效.
>
> 1. 创建俩套rocketmq 版本V4.5.1
> 2. 源mq 创建topic如下
>connector-cluster-topic
>connector-config-topic
>
odbozhou commented on issue #802:
URL:
https://github.com/apache/rocketmq-externals/issues/802#issuecomment-909823263
Please follow the issue guidelines to clearly describe your problem.
Environment, version, code of which project?
--
This is an automated message from the Apache Git Ser
lizhiboo commented on issue #803:
URL:
https://github.com/apache/rocketmq-externals/issues/803#issuecomment-909825781
> In the current design, different workerTasks handle different topics. One
workerTask corresponds to one pullConsumer, which improves concurrency to a
certain extent, so
Johnnyhooyo closed issue #802:
URL: https://github.com/apache/rocketmq-externals/issues/802
--
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
lwclover commented on issue #3308:
URL: https://github.com/apache/rocketmq/issues/3308#issuecomment-909827804
@RongtongJin help me review pr #3295
--
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 t
zhuozl commented on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909836394
@lizhiboo rocketmq cluster is works.
有本地,调试文档吗? 本地idea部署会报如下错误
```
11:08:52.640 [org.reflections-scanner-0] DEBUG org.reflections.Reflections -
[Thread[org.refle
zhuozl commented on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909837000
```
11:08:51.787 [main] INFO o.a.r.connect.runtime.utils.Plugin - Loading
plugin from:
/home/zhuozl/rocketmq/connector-plugins/rocketmq-replicator-0.1.0-SNAPSHOT-jar-wit
zhuozl commented on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
sh run_worker.sh
```
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not
started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq rep
zhuozl edited a comment on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
sh run_worker.sh
```
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not
started.
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq
zhuozl edited a comment on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
sh run_worker.sh topic 复到别外一个集群了. 往源集群topic 发送消息, 目标集群topic 没有收到消息
```
2021-09-01 12:12:34 WARN pool-2-thread-2 - Rocketmq replicator task is not
started.
zhangjidi2016 commented on pull request #6:
URL: https://github.com/apache/rocketmq-dashboard/pull/6#issuecomment-909880405
> @zhangjidi2016
> This branch has conflicts with master, could you resolve the conflicts.
> Thanks.
OK，code conflicts have been resolved
--
This is an
duhenglucky closed pull request #42:
URL: https://github.com/apache/rocketmq-streams/pull/42
--
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-u
duhenglucky merged pull request #43:
URL: https://github.com/apache/rocketmq-streams/pull/43
--
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-u
jeffchanjunwei commented on pull request #3307:
URL: https://github.com/apache/rocketmq/pull/3307#issuecomment-909973258
I am also implementimg this function these days. Maybe I can talk about my
implement. I rewrite the "buildMQClientId" function. The clientId will start
with machineroom
jeffchanjunwei commented on pull request #3295:
URL: https://github.com/apache/rocketmq/pull/3295#issuecomment-909989220
4. 从一个mq集群拉取消息发送到另外一个集群
结果：tps 10w+
最近也在实现跟你一样的功能。@lwclover 你的源和目标集群的规模是多大？同步的时候从源集群消费到发送到目标集群的时候是同步的吧？
--
This is an automated message from the Apache Git Se
jeffchanjunwei closed issue #3210:
URL: https://github.com/apache/rocketmq/issues/3210
--
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
coveralls edited a comment on pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302#issuecomment-909028328
[](https://coveralls.io/builds/42496221)
Coverage increased (+0.03%) to 54.255% when pulling
*
zhuozl edited a comment on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909865714
--
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.
jeffchanjunwei closed issue #3210:
URL: https://github.com/apache/rocketmq/issues/3210
--
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
odbozhou merged pull request #795:
URL: https://github.com/apache/rocketmq-externals/pull/795
--
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-
odbozhou closed issue #798:
URL: https://github.com/apache/rocketmq-externals/issues/798
--
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-unsub
lizhiboo commented on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909823095
> 是否有 rocketmq-replicator更详细的部署文档,根据官方文档部署不生效.
>
> 1. 创建俩套rocketmq 版本V4.5.1
> 2. 源mq 创建topic如下
>connector-cluster-topic
>connector-config-topic
>
jeffchanjunwei commented on pull request #3295:
URL: https://github.com/apache/rocketmq/pull/3295#issuecomment-909989220
4. 从一个mq集群拉取消息发送到另外一个集群
结果：tps 10w+
最近也在实现跟你一样的功能。@lwclover 你的源和目标集群的规模是多大？同步的时候从源集群消费到发送到目标集群的时候是同步的吧？
--
This is an automated message from the Apache Git Se
odbozhou closed issue #796:
URL: https://github.com/apache/rocketmq-externals/issues/796
--
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-unsub
lwclover commented on pull request #3295:
URL: https://github.com/apache/rocketmq/pull/3295#issuecomment-909027145
fix #3308
--
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
odbozhou commented on issue #803:
URL:
https://github.com/apache/rocketmq-externals/issues/803#issuecomment-909821853
In the current design, different workerTasks handle different topics. One
workerTask corresponds to one pullConsumer, which improves concurrency to a
certain extent, so th
StyleTang commented on a change in pull request #14:
URL: https://github.com/apache/rocketmq-dashboard/pull/14#discussion_r699301209
##
File path: LICENSE
##
@@ -413,17 +391,13 @@ Font-Awesome
--
https://github.com/FortAwesome/Font-Awesome
-License
-
-Th
odbozhou commented on issue #798:
URL:
https://github.com/apache/rocketmq-externals/issues/798#issuecomment-909804239
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 comment
zhuozl commented on issue #804:
URL:
https://github.com/apache/rocketmq-externals/issues/804#issuecomment-909836394
--
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 unsu
coveralls commented on pull request #3305:
URL: https://github.com/apache/rocketmq/pull/3305#issuecomment-909671287
[](https://coveralls.io/builds/42534381)
Coverage increased (+0.05%) to 54.143% when pulling
**feb267
odbozhou commented on issue #796:
URL:
https://github.com/apache/rocketmq-externals/issues/796#issuecomment-909803243
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 comment
coveralls commented on pull request #3302:
URL: https://github.com/apache/rocketmq/pull/3302#issuecomment-909028328
[](https://coveralls.io/builds/42495842)
Coverage decreased (-0.02%) to 54.207% when pulling
**f4d2c6
701 - 800 of 44194 matches
Mail list logo
