GitHub user wangwei-ying added a comment to the discussion: why ConsumerClinet
shutdown dot deal START_FAILED status (为什么ConsumerClinet
shutdown的时候不处理START_FAILED状态)
中间状态无法消除,只能通过重启应用解决
GitHub link:
https://github.com/apache/rocketmq/discussions/7369#discussioncomment-7041496
This
GitHub user joeCarf added a comment to the discussion: why ConsumerClinet
shutdown dot deal START_FAILED status (为什么ConsumerClinet
shutdown的时候不处理START_FAILED状态)
可以贴一下详细的操作步骤或代码吗
GitHub link:
https://github.com/apache/rocketmq/discussions/7369#discussioncomment-7041620
This is an
gsh-David opened a new issue, #92:
URL: https://github.com/apache/rocketmq-docker/issues/92
mac m1 linux 虚拟环境下 采用sh build-image.sh 5.1.3 alpine命令无法进行本地镜像编译,产生no
matching manifest for linux/arm64/v8 in the manifest list entries错误,请问如何解决
--
This is an automated message from the Apache Git
GitHub user 41405465 closed a discussion: rocketmq5.0代理模式grpc连接C++客户端多个IP配置问题
broker端采用local模式部署,开启代理模式,grpc端口是18081,共两台机器:ip1:18081;ip2:18081
c++客户端配置endpoint的时候,是只能配一个,还是要配两个,目前发现c++客户端配两个这样的ip会报错:ip1:18081;ip2:18081
broker上面proxy.log报错如下:
Robert-Ro commented on issue #25:
URL:
https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1728732893
[rocketmq sdk] [info] downloading
[https://opensource-rocketmq-client.oss-cn-hangzhou.aliyuncs.com/cpp-client/windows/2.1.0/rocketmq-client-cpp.dll]...
│ [rocketmq
wuteng606 commented on issue #25:
URL:
https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1728893152
你可以自己从rocketmq-client-cpp
也是ali开源的一个仓库里面,把2.1.0的版本下载下来,然后放到自己的oss或者其他文件服务器,配置一下下载地址就可以了
| |
武腾
|
|
***@***.***
|
回复的原邮件
Robert-Ro commented on issue #25:
URL:
https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1728902722
@wuteng606 感谢
--
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
de1star opened a new issue, #143:
URL: https://github.com/apache/rocketmq-client-python/issues/143
Hi apache! I greatly benefit from your rocketmq python client, but I
wondered how to set Message expired time in python client, or do you have a
default expired time in rocketmq?
Look
ifplusor commented on issue #144:
URL:
https://github.com/apache/rocketmq-client-python/issues/144#issuecomment-1758722039
Use env `ROCKETMQ_CLIENT_LOG_DIR `
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
shaligg opened a new issue, #144:
URL: https://github.com/apache/rocketmq-client-python/issues/144
The client log_path :/root/logs/rocketmqlogs
I want change file path,
But I can't find the corresponding API or available environment variables
python 2.7
centos 7
onetwo12cn commented on issue #92:
URL: https://github.com/apache/rocketmq-docker/issues/92#issuecomment-1749851012
mac m1 linux 虚拟环境下 采用sh build-image.sh 5.1.3 alpine命令无法进行本地镜像编译,产生no
matching manifest for linux/arm64/v8 in the manifest list entries错误,请问如何解决
--
This is an automated
allenliule commented on issue #101:
URL:
https://github.com/apache/rocketmq-client-python/issues/101#issuecomment-1750066683
我也遇到了这个问题,查看了一下c++打印的日志,先报的错误是“could not find property mq”,希望大神出来解决这个问题
`[2023-Sep-28 11:41:09.131070](info):updateTopicRouteInfo: didn't get
the
sgkokocool1 opened a new issue, #96:
URL: https://github.com/apache/rocketmq-docker/issues/96
https://github.com/apache/rocketmq-docker/assets/88330169/30d5a46a-3870-4150-8932-23765c9d9a2c;>
--
This is an automated message from the Apache Git Service.
To respond to the message, please
ys270 opened a new issue, #145:
URL: https://github.com/apache/rocketmq-client-python/issues/145
I want to use SQL in expression to filter message properties when consuming
messages, but it seems that I cannot get the messages I want.
I put "Tag=test AND creator=xx" in expression and I
ifplusor commented on issue #145:
URL:
https://github.com/apache/rocketmq-client-python/issues/145#issuecomment-1772144412
It only supports "||" in expression at present.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
ys270 commented on issue #145:
URL:
https://github.com/apache/rocketmq-client-python/issues/145#issuecomment-1774378493
thanks, do you plan to support others in the future?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
988494 opened a new issue, #95:
URL: https://github.com/apache/rocketmq-docker/issues/95
docker-compose.yml
version: '3.8'
# 服务的日志记录配置
services:
# 单机版
rocketmq_nameserver1:
image: apache/rocketmq:5.1.3
container_name: rocketmq_nameserver1
environment:
GitHub user letian-tang edited a discussion: 官方能提供rocketmq5.0 metrics
的grafana的dashboards 模板吗
目前 https://grafana.com/grafana/dashboards/
都是4.0的,不适合5.0
自己弄个又有学习的成本,期待官方放出来一个模版
GitHub link: https://github.com/apache/rocketmq/discussions/7212
This is an automatically sent email for
GitHub user onejimmyboy added a comment to the discussion:
生产环境broker版本从4.5.2升级至4.9.6后硬盘使用率升高一倍
定时删除过期文件不生效?可以看看store.log的日志
GitHub link:
https://github.com/apache/rocketmq/discussions/7215#discussioncomment-6777098
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user joeCarf added a comment to the discussion: 官方能提供rocketmq5.0 metrics
的grafana的dashboards 模板吗
4.x的大盘地址能发一下吗,我参考下能否贡献 :)
GitHub link:
https://github.com/apache/rocketmq/discussions/7212#discussioncomment-6777491
This is an automatically sent email for dev@rocketmq.apache.org.
GitHub user zhiliatom added a comment to the discussion: 官方能提供rocketmq5.0
metrics 的grafana的dashboards 模板吗
hi,look at there
`https://github.com/apache/rocketmq-exporter/blob/master/rocketmq_exporter_overview.json`
GitHub link:
MUCZ opened a new issue, #89:
URL: https://github.com/apache/rocketmq-docker/issues/89
platform: mac pro m2
```
sh build-image.sh 4.5.0 alpine
Version = 4.5.0
[+] Building 1.2s (3/3) FINISHED
GitHub user joeCarf added a comment to the discussion: 消息轨迹希望支持更细粒度的场景
I'd like to try, you can start an issue and assign it to me.
GitHub link:
https://github.com/apache/rocketmq/discussions/7139#discussioncomment-6778966
This is an automatically sent email for dev@rocketmq.apache.org.
GitHub user joeCarf added a comment to the discussion:
哪里可以看到namesrv、broker、proxy 完整的命令行选项 以及配置项樂️
或许可以在脚本中使用 --help?
GitHub link:
https://github.com/apache/rocketmq/discussions/7237#discussioncomment-6801849
This is an automatically sent email for dev@rocketmq.apache.org.
To
HFFZZZ opened a new issue, #90:
URL: https://github.com/apache/rocketmq-docker/issues/90
Why do I have no problem executing quickstart environment inside docker when
I start docker, but I use java client to connect, there will be this exception,
ask for help
java
public static
GitHub user onejimmyboy added a comment to the discussion:
4.7版本,重启consumer,历史一周的消费成功了的消息重新消费了,为什么?
消费者设置的setConsumeFromWhere是否合理?
GitHub link:
https://github.com/apache/rocketmq/discussions/7234#discussioncomment-6799377
This is an automatically sent email for dev@rocketmq.apache.org.
GitHub user DouFuJuShi added a comment to the discussion:
哪里可以看到namesrv、broker、proxy 完整的命令行选项 以及配置项樂️
不全
GitHub link:
https://github.com/apache/rocketmq/discussions/7237#discussioncomment-6808182
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please
GitHub user mz0113 added a comment to the discussion: 事务消息支持分支事务吗?
这简单啊 , 你三个消息回查时候用相同的txId回查不就好了 .
GitHub link:
https://github.com/apache/rocketmq/discussions/6835#discussioncomment-6810771
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an
GitHub user Hoxxx added a comment to the discussion: 5.1如何设置namesrv的日志路径
没事了,改conf下的xml文件
P.S:吐槽下,能否将日志路径合并到一个文件。。
GitHub link:
https://github.com/apache/rocketmq/discussions/7207#discussioncomment-6749389
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe,
GitHub user francisoliverlee added a comment to the discussion:
5.1如何设置namesrv的日志路径
you can update namesv log config by edit conf/logback_namesrv.xml
GitHub link:
https://github.com/apache/rocketmq/discussions/7207#discussioncomment-6766104
This is an automatically sent email for
CyJaySong commented on issue #88:
URL: https://github.com/apache/rocketmq-docker/issues/88#issuecomment-1684712296
```
version: "3"
services:
#Service for nameserver
namesrv:
container_name: RocketMQ-namesrv
image: apache/rocketmq:5.1.3
command: sh
GitHub user alloyinfo added a comment to the discussion:
java17下搭建rocketMQ,broker_default.log 报instrumneted a sprcial java.util.Set into
: sun.nio.ch.EPollSelectorImpl
最新版本5.1.3
GitHub link:
https://github.com/apache/rocketmq/discussions/7274#discussioncomment-6838130
This is an
GitHub user alloyinfo added a comment to the discussion:
java17下搭建rocketMQ,broker_default.log 报instrumneted a sprcial java.util.Set into
: sun.nio.ch.EPollSelectorImpl
local模式搭建成功了,集群没有成功
GitHub link:
https://github.com/apache/rocketmq/discussions/7274#discussioncomment-6838628
This
GitHub user joeCarf added a comment to the discussion:
java17下搭建rocketMQ,broker_default.log 报instrumneted a sprcial java.util.Set into
: sun.nio.ch.EPollSelectorImpl
RcoketMQ目前默认使用1.8进行搭建。java17存在一些封闭类,可能会导致运行时报错。
GitHub link:
GitHub user alloyinfo added a comment to the discussion:
java17下搭建rocketMQ,broker_default.log 报instrumneted a sprcial java.util.Set into
: sun.nio.ch.EPollSelectorImpl
java17下的rocketmq就算不报包的问题,过了几十分钟就会proxy就自己挂掉了
GitHub link:
zkd1998 opened a new issue, #926:
URL: https://github.com/apache/rocketmq-externals/issues/926
The issue tracker is **ONLY** used for bug report and feature request.
Any question or RocketMQ proposal please use our [mailing
lists](http://rocketmq.apache.org/about/contact/).
GitHub user joeCarf added a comment to the discussion:
java17下搭建rocketMQ,broker_default.log 报instrumneted a sprcial java.util.Set into
: sun.nio.ch.EPollSelectorImpl
目前兼容性应该有问题,建议还是使用1.8进行搭建
GitHub link:
https://github.com/apache/rocketmq/discussions/7274#discussioncomment-6839034
GitHub user onejimmyboy added a comment to the discussion: Controller 嵌入
NameServer 部署方式,只有两个节点,停掉broker主节点,从节点不能变成主?
GitHub user cserwen added a comment to the discussion: [Bug] the queue's
messages, span too long, so do flow control
It should be caused by this problem
https://github.com/apache/rocketmq/pull/3861
As for the reason for throwing an exception, it may be that
lollipopjin closed issue #921: [RIP-66] Support KV(Rocksdb) Storage
URL: https://github.com/apache/rocketmq-externals/issues/921
--
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.
lollipopjin merged PR #922:
URL: https://github.com/apache/rocketmq-externals/pull/922
--
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:
fujian-zfj opened a new pull request, #924:
URL: https://github.com/apache/rocketmq-externals/pull/924
## What is the purpose of the change
fix #923
## Brief changelog
rocketmq-rocksdb adds pom.xml
--
This is an automated message from the Apache Git Service.
RongtongJin opened a new pull request, #925:
URL: https://github.com/apache/rocketmq-externals/pull/925
## What is the purpose of the change
Polish the rocketmq-rocksdb pom and readme
## Brief changelog
Polish the rocketmq-rocksdb pom and readme
## Verifying this
RongtongJin merged PR #924:
URL: https://github.com/apache/rocketmq-externals/pull/924
--
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:
RongtongJin closed issue #923: rocketmq-rocksdb adds pom.xml
URL: https://github.com/apache/rocketmq-externals/issues/923
--
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
FourLeafClover commented on issue #25:
URL:
https://github.com/apache/rocketmq-client-nodejs/issues/25#issuecomment-1676800499
@wuteng606 windows版本能用不
--
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
ShannonDing merged PR #925:
URL: https://github.com/apache/rocketmq-externals/pull/925
--
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:
GitHub user tyfprof edited a discussion: RocketMQ5.x 为啥删除了 request-reply
的点对点消息发送答复方式
RocketMQ5.x 为啥删除了 request-reply 的点对点消息发送答复方式。
如果真的删除了,有其它的实现方式吗?谢谢!
GitHub link: https://github.com/apache/rocketmq/discussions/7194
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user onejimmyboy added a comment to the discussion: Controller 嵌入
NameServer 部署方式,只有两个节点,停掉broker主节点,从节点不能变成主?
![image](https://github.com/apache/rocketmq/assets/57432151/1c9d5653-4383-461e-a132-960e479a8c59)
GitHub user onejimmyboy edited a comment on the discussion: Controller 嵌入
NameServer 部署方式,只有两个节点,停掉broker主节点,从节点不能变成主?
![image](https://github.com/apache/rocketmq/assets/57432151/1c9d5653-4383-461e-a132-960e479a8c59)
CyJaySong opened a new issue, #88:
URL: https://github.com/apache/rocketmq-docker/issues/88
使用 docker-compose 在docker 部署5.1.3的namesrv 和 broker
用于开发测试,都启动正常了,但是sdk愣是连接不上,搜了一下,需要启动代理,但是在broker启动时添加了 --enable-proxy
还是不能正常连接,有朋友可以指导一下吗?或者有朋友有现成的docker-compose.yml文件么
--
This is an automated
GitHub user onejimmyboy added a comment to the discussion: Controller 嵌入
NameServer 部署方式,只有两个节点,停掉broker主节点,从节点不能变成主?
破案了,broker配置文件中没有配置brokerIP2,添加上brokerIP2后,正常切换了,brokerIP2=brokerIP1
GitHub link:
https://github.com/apache/rocketmq/discussions/7136#discussioncomment-6719634
This is
GitHub user onejimmyboy closed a discussion: Controller 嵌入 NameServer
部署方式,只有两个节点,停掉broker主节点,从节点不能变成主?
版本:5.1.3
集群形态:Controller嵌入Namesrv部署,一共两个节点,即:controller2节点(嵌入namesrv),broker2节点(1主一从)
现象:启动namesrv、broker。当前集群正常,一主一从。如果stop主节点,此时从节点无法变成主节点。这种情况是否正常。报错信息如下
GitHub user onejimmyboy deleted a comment on the discussion: Controller 嵌入
NameServer 部署方式,只有两个节点,停掉broker主节点,从节点不能变成主?
> 日志显示从节点无法连接到主节点,检查一下连通性
> 日志显示从节点无法连接到主节点,检查一下连通性
GitHub link:
https://github.com/apache/rocketmq/discussions/7136#discussioncomment-6719636
This is an
GitHub user lazyman1992 added a comment to the discussion:
clients-cpp测试延时消息时,出现terminate called without an active exception,不清楚有何问题
感觉是的
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/565#discussioncomment-6849348
This is an automatically sent email for
GitHub user lazyman1992 added a comment to the discussion:
clients-cpp测试延时消息时,出现terminate called without an active exception,不清楚有何问题
感觉是的
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/565#discussioncomment-6849350
This is an automatically sent email for
GitHub user lazyman1992 deleted a comment on the discussion:
clients-cpp测试延时消息时,出现terminate called without an active exception,不清楚有何问题
感觉是的
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/565#discussioncomment-6849348
This is an automatically sent email for
GitHub user mxsm added a comment to the discussion:
request-reply特性(rpc),客户端支持其他语言吗
@ddfnddfn2
你可看一下这个https://github.com/apache/rocketmq-clients,基于proxy的实现。其他语言的实现都是基于proxy来实现的。没有单独的直接实现客户端直连MQ
GitHub link:
https://github.com/apache/rocketmq/discussions/7278#discussioncomment-6850109
GitHub user mxsm edited a comment on the discussion:
request-reply特性(rpc),客户端支持其他语言吗
@ddfnddfn2 你可看一下这个https://github.com/apache/rocketmq-clients,
基于proxy的实现。其他语言的实现都是基于proxy来实现的。没有单独的直接实现客户端直连MQ
GitHub link:
https://github.com/apache/rocketmq/discussions/7278#discussioncomment-6850109
fujian-zfj opened a new pull request, #928:
URL: https://github.com/apache/rocketmq-externals/pull/928
## What is the purpose of the change
fix #927
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
RongtongJin merged PR #928:
URL: https://github.com/apache/rocketmq-externals/pull/928
--
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:
RongtongJin closed issue #927: [rocketmq-rocskdb] change cqUnit size from 36 to
28
URL: https://github.com/apache/rocketmq-externals/issues/927
--
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
RongtongJin opened a new pull request, #930:
URL: https://github.com/apache/rocketmq-externals/pull/930
## What is the purpose of the change
Fix the command for release
## Brief changelog
XX
## Verifying this change
Follow this checklist to help
ShannonDing merged PR #930:
URL: https://github.com/apache/rocketmq-externals/pull/930
--
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:
GitHub user Zintoki added a comment to the discussion:
clients-cpp测试延时消息时,出现terminate called without an active exception,不清楚有何问题
我使用bazel完成了编译,cmake编译我并没有尝试过,cpp 5.x客户端貌似依赖特定版本的库
---原始邮件---
发件人: ***@***.***
发送时间: 2023年8月29日(周二) 中午12:46
收件人: ***@***.***;
抄送: ***@***.**@***.***;
主题: Re:
GitHub user lazyman1992 added a comment to the discussion:
clients-cpp测试延时消息时,出现terminate called without an active exception,不清楚有何问题
cpp怎么编过的啊,关于absl和protobuf一直报错,这两块有版本和CMAKE_CXX_STANDARD的要求么
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/565#discussioncomment-6848839
RongtongJin merged PR #929:
URL: https://github.com/apache/rocketmq-externals/pull/929
--
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:
fujian-zfj opened a new pull request, #929:
URL: https://github.com/apache/rocketmq-externals/pull/929
## What is the purpose of the change
format README
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
john1337 closed issue #78: rocketmq-k8s-helm部署的rocketmq如何在k8s外部使用
URL: https://github.com/apache/rocketmq-docker/issues/78
--
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
GitHub user sun-11y added a comment to the discussion:
开启了acl的情况下,如何在服务端用mqadmin命令创建主题呢?
conf下tools.yml可以配置ak/sk再执行和原来一样的创建topic命令就可以了
GitHub link:
https://github.com/apache/rocketmq/discussions/7186#discussioncomment-6788896
This is an automatically sent email for
GitHub user sun-11y edited a discussion: 非admin 用户为什么可以执行
updateGlobalWhiteAddr操作?
非admin 用户为什么可以执行 updateGlobalWhiteAddr操作? 如果本来配置了用户权限,那通过修改白名单配置是不是也可以绕过权限啊,求助。
GitHub link: https://github.com/apache/rocketmq/discussions/7221
This is an automatically sent email for
GitHub user sun-11y edited a discussion: ACL:非admin 用户为什么可以执行
updateGlobalWhiteAddr操作?
非admin 用户为什么可以执行 updateGlobalWhiteAddr操作? 如果本来配置了用户权限,那通过修改白名单配置是不是也可以绕过权限啊,求助。
GitHub link: https://github.com/apache/rocketmq/discussions/7221
This is an automatically sent email for
GitHub user glpcf added a comment to the discussion: java
5.x官方快速开始代码为什么还要连broker的地址,不是只连proxy吗
1
GitHub link:
https://github.com/apache/rocketmq-clients/discussions/589#discussioncomment-6820688
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please
GitHub user glpcf closed a discussion: java
5.x官方快速开始代码为什么还要连broker的地址,不是只连proxy吗
Exception raised from stream response observer, clientId=##@a5zlvzm8ps,
endpoints=ipv4:172.18.0.4:8081
org.apache.rocketmq.shaded.io.grpc.StatusRuntimeException: UNAVAILABLE: io
exception
at
GitHub user glpcf closed a discussion: java
5.x官方快速开始代码为什么还要连broker的地址,不是只连proxy吗
Exception raised from stream response observer, clientId=##@a5zlvzm8ps,
endpoints=ipv4:172.18.0.4:8081
org.apache.rocketmq.shaded.io.grpc.StatusRuntimeException: UNAVAILABLE: io
exception
at
GitHub user glpcf reopened a discussion: java
5.x官方快速开始代码为什么还要连broker的地址,不是只连proxy吗
Exception raised from stream response observer, clientId=##@a5zlvzm8ps,
endpoints=ipv4:172.18.0.4:8081
org.apache.rocketmq.shaded.io.grpc.StatusRuntimeException: UNAVAILABLE: io
exception
at
GitHub user mz0113 closed the discussion with a comment: 求教 v5.1.0
事务消息Broker回查check()逻辑中 isNeedCheck方法到底要表达什么意思呢?
想通了,解决了
GitHub link:
https://github.com/apache/rocketmq/discussions/7244#discussioncomment-6811208
This is an automatically sent email for dev@rocketmq.apache.org.
To
GitHub user mz0113 closed a discussion: 求教 v5.1.0 事务消息Broker回查check()逻辑中
isNeedCheck方法到底要表达什么意思呢?
```java
boolean isNeedCheck = opMsg == null &&
valueOfCurrentMinusBorn > checkImmunityTime
|| opMsg != null && opMsg.get(opMsg.size() -
GitHub user n1nja8 closed the discussion with a comment:
生产者先于消费者启动,并在消费者启动之前投递了一些消息,消费者启动后为啥不能消费那些已投递但未消费的消息?
> 若队列 minOffset 为0,且数据还在内存中,则会从 0 开始消费
想问一下这里这样设置的目的是什么?
GitHub link:
https://github.com/apache/rocketmq/discussions/6702#discussioncomment-6811305
This is an
fei-ghb commented on issue #115:
URL:
https://github.com/apache/rocketmq-client-python/issues/115#issuecomment-1803116176
install rocketmq-client-cpp-2.0.0-centos7-x86_64
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
treelly commented on issue #115:
URL:
https://github.com/apache/rocketmq-client-python/issues/115#issuecomment-1803116441
您好,邮件已收到!
--
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
cryptoya commented on PR #69:
URL: https://github.com/apache/rocketmq-docker/pull/69#issuecomment-1413225670
>
`image-build-ci` is mainly used for CI in the RocketMQ repository
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
shane965 commented on issue #127:
URL:
https://github.com/apache/rocketmq-client-python/issues/127#issuecomment-1463195900
> you should create a class, `consumer.shutdown()` as new function of the
class
Thank you for your reply. I will try it when I have time.
--
This is an
shane965 closed issue #127: readme example consumer.shutdown() is unreachable
URL: https://github.com/apache/rocketmq-client-python/issues/127
--
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
wenlincheng opened a new issue, #133:
URL: https://github.com/apache/rocketmq-client-python/issues/133
为啥不支持windows?
--
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
johnny2002 opened a new issue, #904:
URL: https://github.com/apache/rocketmq-externals/issues/904
The issue tracker is **ONLY** used for bug report and feature request.
Any question or RocketMQ proposal please use our [mailing
lists](http://rocketmq.apache.org/about/contact/).
hahait commented on issue #903:
URL:
https://github.com/apache/rocketmq-externals/issues/903#issuecomment-1482444781
这个问题,已经解决: 在安装 rocketmq input 插件时,要下载 logstash 官方提供的二进制包(与编译的 logstash
同版本),将插件装在这个二进制包里;
--
This is an automated message from the Apache Git Service.
To respond to the
hahait closed issue #903: rocketmq-logstash-input installation failure
URL: https://github.com/apache/rocketmq-externals/issues/903
--
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
shusqn commented on issue #64:
URL: https://github.com/apache/rocketmq-docker/issues/64#issuecomment-1465455837
Where is 5.0
--
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.
miner-k commented on issue #128:
URL:
https://github.com/apache/rocketmq-client-python/issues/128#issuecomment-1458127111
from rocketmq.client import Producer, Message
# 创建消费者,指定groupid的名称
producer = Producer('PID-python')
# 设置nameserver的地址
miner-k commented on issue #127:
URL:
https://github.com/apache/rocketmq-client-python/issues/127#issuecomment-1458132146
you should create a class, `consumer.shutdown()` as new function of the
class
--
This is an automated message from the Apache Git Service.
To respond to the
hahait opened a new issue, #903:
URL: https://github.com/apache/rocketmq-externals/issues/903
The issue tracker is **ONLY** used for bug report and feature request.
Any question or RocketMQ proposal please use our [mailing
lists](http://rocketmq.apache.org/about/contact/).
licfan commented on issue #128:
URL:
https://github.com/apache/rocketmq-client-python/issues/128#issuecomment-1471726078
我也遇到了这个问题,大概90%的流量都在一个queue, 其他10%的流量分布在其余若干个queue,请问你解决了吗?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Jzow closed pull request #2: [Fix] Missing part
URL: https://github.com/apache/rocketmq-client-rust/pull/2
--
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,
xzkzdx opened a new issue, #132:
URL: https://github.com/apache/rocketmq-client-python/issues/132
Mac M2 装好环境后报以下错误 librocketmq.dylib是rocketmqV2.0.0版本下载的
OSError: dlopen(/usr/local/lib/librocketmq.dylib, 0x0006): tried:
'/usr/local/lib/librocketmq.dylib' (mach-o file, but is an
ddatsh opened a new issue, #902:
URL: https://github.com/apache/rocketmq-externals/issues/902
https://www.elastic.co/guide/en/apm/agent/java/current/community-plugins.html
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
ifplusor commented on issue #132:
URL:
https://github.com/apache/rocketmq-client-python/issues/132#issuecomment-1442759666
I think the pre-compiled librocketmq binary in readme and pypi do not
support M2 now, you can [compile it from
xzkzdx commented on issue #132:
URL:
https://github.com/apache/rocketmq-client-python/issues/132#issuecomment-1442795807
build bad, not support gcc4.8.2,use gcc12 also build error like this '***
Configuration arm-apple-darwin22.2.0 not supported'.
--
This is an automated message from
xzkzdx commented on issue #132:
URL:
https://github.com/apache/rocketmq-client-python/issues/132#issuecomment-1442901774
using master branch of https://github.com/apache/rocketmq-client-cpp , and
download
[openssl-3.0.8.tar.gz](https://www.openssl.org/source/openssl-3.0.8.tar.gz) ,
and
xiang1030 commented on issue #132:
URL:
https://github.com/apache/rocketmq-client-python/issues/132#issuecomment-1442720881
Yes,All according to Readme.
--
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
101 - 200 of 896 matches
Mail list logo