This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-docker.git
from cb46b84 Merge pull request #101 from zzjcool/feat/rmq5-docker
add c00652a fix: use docker compose v
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-docker.git
commit 962ffc74b14867231e330a451f6671f587bf24cf
Merge: cb46b84 c00652a
Author: Zhanhui Li
AuthorDate: Wed Feb 21 16
The GitHub Actions job "Rust Coverage" on rocketmq-clients.git has succeeded.
Run started by GitHub user glcrazier (triggered by glcrazier).
Head commit for run:
0871eb68242d5a8695429e947bad6126de561025 / qipingluo
enable local-offset feature on time module
Report URL: https://github.com/apach
codecov-commenter commented on PR #682:
URL: https://github.com/apache/rocketmq-clients/pull/682#issuecomment-1956115310
##
[Codecov](https://app.codecov.io/gh/apache/rocketmq-clients/pull/682?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm
The GitHub Actions job "Build" on rocketmq-clients.git has failed.
Run started by GitHub user glcrazier (triggered by glcrazier).
Head commit for run:
0871eb68242d5a8695429e947bad6126de561025 / qipingluo
enable local-offset feature on time module
Report URL: https://github.com/apache/rocketmq-
The GitHub Actions job "Build" on rocketmq-clients.git has failed.
Run started by GitHub user glcrazier (triggered by glcrazier).
Head commit for run:
c21112dcd505d871fc2707ecb1ce40df05fac9d1 / qipingluo
use tokio RwLock instead of parking_lot version
Report URL: https://github.com/apache/rock
The GitHub Actions job "Build" on rocketmq-clients.git has succeeded.
Run started by GitHub user glcrazier (triggered by glcrazier).
Head commit for run:
77f4af84f74b5ba83622bfddee67bf32ae3355fa / qipingluo
reformat code
Report URL: https://github.com/apache/rocketmq-clients/actions/runs/79862
lizhanhui commented on code in PR #682:
URL: https://github.com/apache/rocketmq-clients/pull/682#discussion_r1497165946
##
rust/src/producer.rs:
##
@@ -118,7 +196,53 @@ impl Producer {
Ok(())
}
-fn transform_messages_to_protobuf(
+async fn handle_recover_
glcrazier commented on code in PR #682:
URL: https://github.com/apache/rocketmq-clients/pull/682#discussion_r1497177364
##
rust/src/producer.rs:
##
@@ -118,7 +196,53 @@ impl Producer {
Ok(())
}
-fn transform_messages_to_protobuf(
+async fn handle_recover_
absolute8511 commented on code in PR #7649:
URL: https://github.com/apache/rocketmq/pull/7649#discussion_r1497200242
##
broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java:
##
@@ -522,6 +534,11 @@ private synchronized RemotingCommand
updateBroker
RongtongJin commented on code in PR #7649:
URL: https://github.com/apache/rocketmq/pull/7649#discussion_r1497218316
##
broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java:
##
@@ -522,6 +534,11 @@ private synchronized RemotingCommand
updateBrokerC
DongyuanPan commented on code in PR #238:
URL: https://github.com/apache/rocketmq-mqtt/pull/238#discussion_r1497522276
##
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ssl/SslFactory.java:
##
@@ -71,6 +76,55 @@ private void initSslContext() {
}
}
+
lizhanhui commented on code in PR #682:
URL: https://github.com/apache/rocketmq-clients/pull/682#discussion_r1497660393
##
rust/src/producer.rs:
##
@@ -93,23 +116,80 @@ impl Producer {
};
let logger = log::logger(option.logging_format());
let settings
glcrazier commented on code in PR #682:
URL: https://github.com/apache/rocketmq-clients/pull/682#discussion_r1497689223
##
rust/src/producer.rs:
##
@@ -93,23 +116,80 @@ impl Producer {
};
let logger = log::logger(option.logging_format());
let settings
lizhanhui commented on code in PR #682:
URL: https://github.com/apache/rocketmq-clients/pull/682#discussion_r1497711161
##
rust/src/producer.rs:
##
@@ -93,23 +116,80 @@ impl Producer {
};
let logger = log::logger(option.logging_format());
let settings
lizhanhui merged PR #682:
URL: https://github.com/apache/rocketmq-clients/pull/682
--
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: commits-unsubscr...@r
lizhanhui closed issue #634: [Rust] failed to parse config at
client.handle_telemetry_command sending messages
URL: https://github.com/apache/rocketmq-clients/issues/634
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
lizhanhui closed issue #598: [Bug] Rust client Failed to parse config at
client.handle_telemetry_command
URL: https://github.com/apache/rocketmq-clients/issues/598
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 2eedee02 [rust] support handling se
lizhanhui opened a new issue, #683:
URL: https://github.com/apache/rocketmq-clients/issues/683
### Programming Language of the Client
Rust
### Is Your Feature Request Related to a Problem?
We need to align features with Java/C++/...
### Describe the Solution You'd
lizhanhui opened a new issue, #684:
URL: https://github.com/apache/rocketmq-clients/issues/684
### Programming Language of the Client
Rust
### Is Your Feature Request Related to a Problem?
Tokio-tracing offers more intuitive observation, experience than what slog
can, in
lizhanhui commented on issue #678:
URL:
https://github.com/apache/rocketmq-clients/issues/678#issuecomment-1956864250
To my knowledge, it's still at the alpha stage.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
mxsm opened a new issue, #7845:
URL: https://github.com/apache/rocketmq/issues/7845
### Before Creating the Enhancement Request
- [X] I have confirmed that this should be classified as an enhancement
rather than a bug/feature.
### Summary
 This PR Fixes
Fixes #7845
### Brief Description
- Simplify the AbstractSendMessageProcessor#buildMsgContext code using
Optional
### How
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has
failed.
Run started by GitHub user mxsm (triggered by mxsm).
Head commit for run:
77e9915c8494dba616c4a0062127e5fdb7ab7e65 / mxsm
[ISSUE #7845]implify the AbstractSendMessageProcessor#buildMsgContext code
using Optional
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user mxsm (triggered by mxsm).
Head commit for run:
0b05e9c7c13d1016057bd17dd12f4cc0238feb39 / mxsm
[ISSUE #7840] Update the version in the README.md document to 5.2.0 (#7841)
Report URL: https
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has
succeeded.
Run started by GitHub user mxsm (triggered by mxsm).
Head commit for run:
77e9915c8494dba616c4a0062127e5fdb7ab7e65 / mxsm
[ISSUE #7845]implify the AbstractSendMessageProcessor#buildMsgContext code
using Optio
github-actions[bot] commented on issue #6129:
URL: https://github.com/apache/rocketmq/issues/6129#issuecomment-1958423913
This issue is stale because it has been open for 365 days with no activity.
It will be closed in 3 days if no further activity occurs.
--
This is an automated message
github-actions[bot] commented on issue #6098:
URL: https://github.com/apache/rocketmq/issues/6098#issuecomment-1958423965
This issue was closed because it has been inactive for 3 days since being
marked as stale.
--
This is an automated message from the Apache Git Service.
To respond to t
github-actions[bot] commented on PR #3172:
URL: https://github.com/apache/rocketmq/pull/3172#issuecomment-1958424026
This PR is stale because it has been open for 365 days with no activity. It
will be closed in 3 days if no further activity occurs. If you wish not to mark
it as stale, pleas
github-actions[bot] commented on issue #6086:
URL: https://github.com/apache/rocketmq/issues/6086#issuecomment-1958423993
This issue was closed because it has been inactive for 3 days since being
marked as stale.
--
This is an automated message from the Apache Git Service.
To respond to t
github-actions[bot] closed issue #6086: getSystemTopicListFromBroker shoule
contains topics which startwith rmq_sys_
URL: https://github.com/apache/rocketmq/issues/6086
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
github-actions[bot] commented on PR #2959:
URL: https://github.com/apache/rocketmq/pull/2959#issuecomment-1958424062
This PR is stale because it has been open for 365 days with no activity. It
will be closed in 3 days if no further activity occurs. If you wish not to mark
it as stale, pleas
github-actions[bot] commented on PR #2932:
URL: https://github.com/apache/rocketmq/pull/2932#issuecomment-1958424093
This PR is stale because it has been open for 365 days with no activity. It
will be closed in 3 days if no further activity occurs. If you wish not to mark
it as stale, pleas
github-actions[bot] commented on PR #2829:
URL: https://github.com/apache/rocketmq/pull/2829#issuecomment-1958424118
This PR is stale because it has been open for 365 days with no activity. It
will be closed in 3 days if no further activity occurs. If you wish not to mark
it as stale, pleas
github-actions[bot] commented on PR #2487:
URL: https://github.com/apache/rocketmq/pull/2487#issuecomment-1958424150
This PR is stale because it has been open for 365 days with no activity. It
will be closed in 3 days if no further activity occurs. If you wish not to mark
it as stale, pleas
github-actions[bot] commented on PR #1947:
URL: https://github.com/apache/rocketmq/pull/1947#issuecomment-1958424171
This PR is stale because it has been open for 365 days with no activity. It
will be closed in 3 days if no further activity occurs. If you wish not to mark
it as stale, pleas
github-actions[bot] commented on PR #1874:
URL: https://github.com/apache/rocketmq/pull/1874#issuecomment-1958424197
This PR is stale because it has been open for 365 days with no activity. It
will be closed in 3 days if no further activity occurs. If you wish not to mark
it as stale, pleas
github-actions[bot] commented on PR #1606:
URL: https://github.com/apache/rocketmq/pull/1606#issuecomment-1958424220
This PR is stale because it has been open for 365 days with no activity. It
will be closed in 3 days if no further activity occurs. If you wish not to mark
it as stale, pleas
glcrazier commented on issue #683:
URL:
https://github.com/apache/rocketmq-clients/issues/683#issuecomment-1958471139
I'd like to take a shot. Is there anything required before I submit the PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
lizhanhui commented on issue #683:
URL:
https://github.com/apache/rocketmq-clients/issues/683#issuecomment-1958510987
> I'd like to take a shot. Is there anything required before I submit the PR?
Implementing this feature would result in a large change set, in order to
make the devel
glcrazier commented on issue #683:
URL:
https://github.com/apache/rocketmq-clients/issues/683#issuecomment-1958527261
> > I'd like to take a shot. Is there anything required before I submit the
PR?
>
> Implementing this feature would result in a large change set, in order to
make th
leizhiyuan commented on issue #7842:
URL: https://github.com/apache/rocketmq/issues/7842#issuecomment-1958577456
FIFO topic + FIFO consumer？
this scene，will etry infinitely，do not set anything in consumerGroup config
or normal topic，normal consumer
--
This is an automated
leizhiyuan commented on issue #7839:
URL: https://github.com/apache/rocketmq/issues/7839#issuecomment-1958589760
2024-01-16 17:50:30 INFO ReadSocketService - join thread[FlowMonitor],
elapsed time: 0ms, join time:9ms
this log only printed in shutdown , and this is ha scene, you sh
yanhom1314 commented on PR #4267:
URL: https://github.com/apache/rocketmq/pull/4267#issuecomment-1958611837
Can this PR be 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 com
pingww merged PR #238:
URL: https://github.com/apache/rocketmq-mqtt/pull/238
--
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: commits-unsubscr...@rocketm
This is an automated email from the ASF dual-hosted git repository.
pingww pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
from 0d51d3a Merge pull request #227 from
EssinZhang/delete-logback-conflict
add 6072ead feat: Hot reload s
This is an automated email from the ASF dual-hosted git repository.
pingww pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit 4331ec4b557e116cacede8f5729a14e1c3964212
Merge: 0d51d3a 6072ead
Author: pingww
AuthorDate: Thu Feb 22 15:23:29 2
redlsz opened a new issue, #7848:
URL: https://github.com/apache/rocketmq/issues/7848
### Before Creating the Bug Report
- [X] I found a bug, not just asking a question, which should be created in
[GitHub Discussions](https://github.com/apache/rocketmq/discussions).
- [X] I hav
lokistars commented on PR #7566:
URL: https://github.com/apache/rocketmq/pull/7566#issuecomment-1958884385
> 错误测试： DefaultLitePullConsumerTest.unnecessary Mockito 存根 »
UnnecessaryStubbing
org.apache.rocketmq.client.consumer.DefaultMQPushConsumerTest.org.apache.rocketmq.client.consumer.Defau
redlsz commented on issue #7848:
URL: https://github.com/apache/rocketmq/issues/7848#issuecomment-1958889091
https://github.com/apache/rocketmq/assets/103550934/397440df-9c83-4026-abb8-7b38baa7de09";>
The property PROPERTY_INNER_MULTI_DISPATCH and
PROPERTY_INNER_MULTI_QUEUE_OFFSET may
Yelijah commented on issue #7842:
URL: https://github.com/apache/rocketmq/issues/7842#issuecomment-1958891202
> FIFO topic + FIFO consumer？
>
> this scene，will etry infinitely，do not set anything in consumerGroup config
>
> or normal topic，normal consumer
FIFO topic + FIF
52 matches
Mail list logo
