[GitHub] [rocketmq-spring] MrZbb commented on issue #556: 使用RocketMQMessageListener订阅多个topic的问题

2023-08-30 Thread via GitHub
MrZbb commented on issue #556: URL: https://github.com/apache/rocketmq-spring/issues/556#issuecomment-1699040584 > 老哥解决了吗? 最后一个应用实例针对不同topic用的不同consumer-group...只能这样了 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [rocketmq] lizhimins commented on a diff in pull request #7281: [ISSUE#7280] Fix and refactor handle commit exception in tiered storage

2023-08-30 Thread via GitHub
lizhimins commented on code in PR #7281: URL: https://github.com/apache/rocketmq/pull/7281#discussion_r1310012901 ## tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/TieredFileSegment.java: ## @@ -333,99 +318,148 @@ public boolean commit() { if

[GitHub] [rocketmq] yuz10 opened a new pull request, #7284: [#7283] Incorrect dledger commitlog min offset after mappedFile re delete failed

2023-08-30 Thread via GitHub
yuz10 opened a new pull request, #7284: URL: https://github.com/apache/rocketmq/pull/7284 ### Which Issue(s) This PR Fixes Fixes #7283 ### Brief Description ### How Did You Test This Change? -- This is an automated message from the

[GitHub] [rocketmq] lizhimins commented on a diff in pull request #7281: [ISSUE#7280] Fix and refactor handle commit exception in tiered storage

2023-08-30 Thread via GitHub
lizhimins commented on code in PR #7281: URL: https://github.com/apache/rocketmq/pull/7281#discussion_r1309998728 ## tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/stream/FileSegmentInputStream.java: ## @@ -95,18 +96,34 @@ public synchronized void reset()

[GitHub] [rocketmq] shirenchuang commented on a diff in pull request #7258: Enhancement getNamesrvAddr trim #7252

2023-08-30 Thread via GitHub
shirenchuang commented on code in PR #7258: URL: https://github.com/apache/rocketmq/pull/7258#discussion_r1309958414 ## client/src/main/java/org/apache/rocketmq/client/ClientConfig.java: ## @@ -215,7 +215,7 @@ public ClientConfig cloneClientConfig() { public String

[GitHub] [rocketmq] yuz10 opened a new issue, #7283: [Bug] Incorrect dledger commitlog min offset after mappedFile re delete failed.

2023-08-30 Thread via GitHub
yuz10 opened a new issue, #7283: URL: https://github.com/apache/rocketmq/issues/7283 ### 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

[GitHub] [rocketmq-clients] eventhorizon-cli closed pull request #595: Merge pull request #1 from apache/master

2023-09-05 Thread via GitHub
eventhorizon-cli closed pull request #595: Merge pull request #1 from apache/master URL: https://github.com/apache/rocketmq-clients/pull/595 -- 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

[GitHub] [rocketmq] codecov-commenter commented on pull request #7298: [ISSUE #7295] Reserve time for next retrial when send message.

2023-09-05 Thread via GitHub
codecov-commenter commented on PR #7298: URL: https://github.com/apache/rocketmq/pull/7298#issuecomment-1706459295 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7298?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq-operator] drivebyer opened a new issue, #176: [Feature Request] Support Manage Multi RocketMQ cluster

2023-09-03 Thread via GitHub
drivebyer opened a new issue, #176: URL: https://github.com/apache/rocketmq-operator/issues/176 ## Please describe the feature you are requesting. I propose the enhancement of the current operator to support the management of multiple RocketMQ clusters by a single operator. ##

[GitHub] [rocketmq] github-actions[bot] commented on issue #4966: Optimize ThreadLocalIndex

2023-09-02 Thread via GitHub
github-actions[bot] commented on issue #4966: URL: https://github.com/apache/rocketmq/issues/4966#issuecomment-1703968635 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] [rocketmq] github-actions[bot] commented on issue #4949: Fix 'Address already in use' in AutoSwitchRoleIntegrationTest#testCheckSyncStateSet

2023-09-02 Thread via GitHub
github-actions[bot] commented on issue #4949: URL: https://github.com/apache/rocketmq/issues/4949#issuecomment-1703968642 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] [rocketmq] github-actions[bot] commented on issue #4945: Adjust the storedir format of test cases to the Windows platform

2023-09-02 Thread via GitHub
github-actions[bot] commented on issue #4945: URL: https://github.com/apache/rocketmq/issues/4945#issuecomment-1703968650 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] [rocketmq] github-actions[bot] closed issue #4833: Some Junit test failed when use windows system

2023-09-02 Thread via GitHub
github-actions[bot] closed issue #4833: Some Junit test failed when use windows system URL: https://github.com/apache/rocketmq/issues/4833 -- 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

[GitHub] [rocketmq] github-actions[bot] commented on pull request #4797: [ISSUE #4771]In HA mode, if you do not truncate consumerOffsetMap, it may cause a bug

2023-09-02 Thread via GitHub
github-actions[bot] commented on PR #4797: URL: https://github.com/apache/rocketmq/pull/4797#issuecomment-1703968662 This PR 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 the

[GitHub] [rocketmq] github-actions[bot] closed pull request #4797: [ISSUE #4771]In HA mode, if you do not truncate consumerOffsetMap, it may cause a bug

2023-09-02 Thread via GitHub
github-actions[bot] closed pull request #4797: [ISSUE #4771]In HA mode, if you do not truncate consumerOffsetMap, it may cause a bug URL: https://github.com/apache/rocketmq/pull/4797 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [rocketmq] github-actions[bot] closed issue #3207: Improve the topicPublishInfo cache in producer

2023-09-02 Thread via GitHub
github-actions[bot] closed issue #3207: Improve the topicPublishInfo cache in producer URL: https://github.com/apache/rocketmq/issues/3207 -- 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

[GitHub] [rocketmq-operator] drivebyer commented on pull request #63: [ISSUE 57] add rocketmq api

2023-09-03 Thread via GitHub
drivebyer commented on PR #63: URL: https://github.com/apache/rocketmq-operator/pull/63#issuecomment-1704532681 still need this -- 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

[GitHub] [rocketmq-site] ShannonDing merged pull request #591: Correct release date for 5.1.3

2023-09-03 Thread via GitHub
ShannonDing merged PR #591: URL: https://github.com/apache/rocketmq-site/pull/591 -- 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] [rocketmq] codecov-commenter commented on pull request #7290: [ISSUE #7289] Fixed asynchronous send backpressure capability

2023-09-03 Thread via GitHub
codecov-commenter commented on PR #7290: URL: https://github.com/apache/rocketmq/pull/7290#issuecomment-1704556986 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7290?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq] guyinyou opened a new pull request, #7290: [ISSUE #7289] Fixed asynchronous send backpressure capability

2023-09-03 Thread via GitHub
guyinyou opened a new pull request, #7290: URL: https://github.com/apache/rocketmq/pull/7290 ### Which Issue(s) This PR Fixes Fixes #7289 ### Brief Description ### How Did You Test This Change? -- This is an automated message from

[GitHub] [rocketmq] guyinyou opened a new issue, #7289: [Enhancement] Fixed asynchronous send backpressure capability

2023-09-03 Thread via GitHub
guyinyou opened a new issue, #7289: URL: https://github.com/apache/rocketmq/issues/7289 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Fixed asynchronous send

[GitHub] [rocketmq] RongtongJin merged pull request #7290: [ISSUE #7289] Fixed asynchronous send backpressure capability

2023-09-04 Thread via GitHub
RongtongJin merged PR #7290: URL: https://github.com/apache/rocketmq/pull/7290 -- 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] [rocketmq] RongtongJin closed issue #7289: [Enhancement] Fixed asynchronous send backpressure capability

2023-09-04 Thread via GitHub
RongtongJin closed issue #7289: [Enhancement] Fixed asynchronous send backpressure capability URL: https://github.com/apache/rocketmq/issues/7289 -- 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

[GitHub] [rocketmq-client-go] wenxuwan opened a new pull request, #1090: seperate interface and implement

2023-09-04 Thread via GitHub
wenxuwan opened a new pull request, #1090: URL: https://github.com/apache/rocketmq-client-go/pull/1090 ## What is the purpose of the change X ## Brief changelog XX ## Verifying this change Follow this checklist to help us incorporate your

[GitHub] [rocketmq-client-go] wenxuwan closed pull request #1090: seperate interface and implement

2023-09-04 Thread via GitHub
wenxuwan closed pull request #1090: seperate interface and implement URL: https://github.com/apache/rocketmq-client-go/pull/1090 -- 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.

[GitHub] [rocketmq-site] RongtongJin opened a new pull request, #591: Correct release date for 5.1.3

2023-09-03 Thread via GitHub
RongtongJin opened a new pull request, #591: URL: https://github.com/apache/rocketmq-site/pull/591 Please do not create a Pull Request without creating an issue first. ## What is the purpose of the change Correct release date for 5.1.3 ## Brief changelog XX

[GitHub] [rocketmq] mufengCc commented on issue #7187: [Bug] RocketMQ consumer消费不到第一条消息

2023-09-03 Thread via GitHub
mufengCc commented on issue #7187: URL: https://github.com/apache/rocketmq/issues/7187#issuecomment-1704539822 还真的是。我也复现这个问题了。 同样的5.1.3版本 -- 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

[GitHub] [rocketmq] dev-techmoe opened a new issue, #7304: [Bug] [Client] DefaultLitePullConsumerImpl.poll not working correct

2023-09-05 Thread via GitHub
dev-techmoe opened a new issue, #7304: URL: https://github.com/apache/rocketmq/issues/7304 ### 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]

[GitHub] [rocketmq] RongtongJin merged pull request #7303: [ISSUE #7302] Fix singleTopicRegister code deleted in merge

2023-09-06 Thread via GitHub
RongtongJin merged PR #7303: URL: https://github.com/apache/rocketmq/pull/7303 -- 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] [rocketmq] echooymxq opened a new issue, #7306: [Enhancement]Create sys topic subscription when autoCreateSubscriptionGroup false

2023-09-06 Thread via GitHub
echooymxq opened a new issue, #7306: URL: https://github.com/apache/rocketmq/issues/7306 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary At proxy mode, we use

[GitHub] [rocketmq] codecov-commenter commented on pull request #7303: Fix singleTopicRegister code deleted in merge

2023-09-05 Thread via GitHub
codecov-commenter commented on PR #7303: URL: https://github.com/apache/rocketmq/pull/7303#issuecomment-1707600910 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7303?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq] yulangz opened a new pull request, #7301: jRaft-Controller Implemention

2023-09-05 Thread via GitHub
yulangz opened a new pull request, #7301: URL: https://github.com/apache/rocketmq/pull/7301 ### Which Issue(s) This PR Fixes Fixes #7300 ### Brief Description Use [JRaft](https://github.com/sofastack/sofa-jraft) to Implement Controller. New Configuration

[GitHub] [rocketmq] codecov-commenter commented on pull request #7307: [ISSUE #7305] Fix metrics and transactional module not shutdown while broker offline cause coredump

2023-09-06 Thread via GitHub
codecov-commenter commented on PR #7307: URL: https://github.com/apache/rocketmq/pull/7307#issuecomment-1707781706 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7307?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq] codecov-commenter commented on pull request #7301: [ISSUE #7300] jRaft-Controller Implemention

2023-09-05 Thread via GitHub
codecov-commenter commented on PR #7301: URL: https://github.com/apache/rocketmq/pull/7301#issuecomment-1707575067 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7301?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq-client-go] gougousha commented on issue #1092: 集群环境下,不同机器获取到同一个topic的消息队列不一致

2023-09-05 Thread via GitHub
gougousha commented on issue #1092: URL: https://github.com/apache/rocketmq-client-go/issues/1092#issuecomment-1707575838 另一条机器 {"log.level":"INFO","time":"2023-09-05T09:58:19.195Z","log.origin.file.name":"rocketmq/producer.go:108","msg":"HashQueueSelector

[GitHub] [rocketmq-client-go] gougousha opened a new issue, #1092: 集群环境下,不同机器获取到同一个topic的消息队列不一致

2023-09-05 Thread via GitHub
gougousha opened a new issue, #1092: URL: https://github.com/apache/rocketmq-client-go/issues/1092 {"log.level":"INFO","time":"2023-09-05T09:58:19.201Z","log.origin.file.name":"rocketmq/producer.go:108","msg":"HashQueueSelector

[GitHub] [rocketmq] yuz10 opened a new issue, #7302: [Bug] singleTopicRegister code deleted in merge

2023-09-05 Thread via GitHub
yuz10 opened a new issue, #7302: URL: https://github.com/apache/rocketmq/issues/7302 ### 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

[GitHub] [rocketmq] lizhimins opened a new issue, #7305: [Bug] Fix metrics and transactional not shutdown cause broker coredump

2023-09-06 Thread via GitHub
lizhimins opened a new issue, #7305: URL: https://github.com/apache/rocketmq/issues/7305 ### 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

[GitHub] [rocketmq] yulangz opened a new issue, #7300: [Enhancement] Use JRaft to Implement Controller

2023-09-05 Thread via GitHub
yulangz opened a new issue, #7300: URL: https://github.com/apache/rocketmq/issues/7300 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary The Controller is

[GitHub] [rocketmq] lizhimins opened a new pull request, #7307: [ISSUE #7305] Fix metrics and transactional not shutdown cause broker coredump

2023-09-06 Thread via GitHub
lizhimins opened a new pull request, #7307: URL: https://github.com/apache/rocketmq/pull/7307 … coredump ### Which Issue(s) This PR Fixes Fixes #7305 ### Brief Description ### How Did You Test This Change? -- This is an

[GitHub] [rocketmq] echooymxq commented on issue #7306: [Enhancement]Create sys topic subscription when autoCreateSubscriptionGroup false

2023-09-06 Thread via GitHub
echooymxq commented on issue #7306: URL: https://github.com/apache/rocketmq/issues/7306#issuecomment-1707757131 /cc @xdkxlk @drpmma -- 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

[GitHub] [rocketmq-spring] mufengCc commented on issue #583: 使用starter的时候需要自定义全局拦截器在 listener onMessage 之前处理 MessageExt

2023-09-04 Thread via GitHub
mufengCc commented on issue #583: URL: https://github.com/apache/rocketmq-spring/issues/583#issuecomment-1704876301 写的不错,很有想法。 个人认为,作者没有实现扩展接口,可能另有考虑。 另外,如果要针对rocketMQ实现链路追踪,需要生产者在发送消息时,通过`properties`增加对应值。在消费者端,使用aop进行处理,也很方便 下面是我的代码示例 `@Slf4j @Aspect

[GitHub] [rocketmq-spring] mufengCc commented on issue #556: 使用RocketMQMessageListener订阅多个topic的问题

2023-09-04 Thread via GitHub
mufengCc commented on issue #556: URL: https://github.com/apache/rocketmq-spring/issues/556#issuecomment-1704939340 ![image](https://github.com/apache/rocketmq-spring/assets/48708389/48dc7408-b3b0-4edb-83cb-1734691b5ad9)

[GitHub] [rocketmq-operator] stringang opened a new issue, #177: broker GC log files filling up sandboxes disk space

2023-09-04 Thread via GitHub
stringang opened a new issue, #177: URL: https://github.com/apache/rocketmq-operator/issues/177 1. Please describe the issue you observed: After the `broker` has been running for a while, the `shm` on the host sends out a space-filling alarm. the mount point for

[GitHub] [rocketmq-spring] 15521935616 commented on issue #556: 使用RocketMQMessageListener订阅多个topic的问题

2023-09-04 Thread via GitHub
15521935616 commented on issue #556: URL: https://github.com/apache/rocketmq-spring/issues/556#issuecomment-1705506196 > ![image](https://user-images.githubusercontent.com/48708389/265418956-48dc7408-b3b0-4edb-83cb-1734691b5ad9.png) > >

[GitHub] [rocketmq] lizhimins merged pull request #7310: [ISSUE #7308] Adding topic blacklist and filter in tiered storage module

2023-09-06 Thread via GitHub
lizhimins merged PR #7310: URL: https://github.com/apache/rocketmq/pull/7310 -- 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] [rocketmq] lizhimins closed issue #7308: [Enhancement] Adding topic blacklist and filter to tiered storage module

2023-09-06 Thread via GitHub
lizhimins closed issue #7308: [Enhancement] Adding topic blacklist and filter to tiered storage module URL: https://github.com/apache/rocketmq/issues/7308 -- 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

[GitHub] [rocketmq] lizhimins opened a new issue, #7308: [Enhancement] Adding topic whitelist and filter to tiered storage module

2023-09-06 Thread via GitHub
lizhimins opened a new issue, #7308: URL: https://github.com/apache/rocketmq/issues/7308 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary In the current design

[GitHub] [rocketmq] kang-hl opened a new pull request, #7309: Correct wrong value

2023-09-06 Thread via GitHub
kang-hl opened a new pull request, #7309: URL: https://github.com/apache/rocketmq/pull/7309 ### Which Issue(s) This PR Fixes Fixes #issue_id ### Brief Description ### How Did You Test This Change? -- This is an automated message

[GitHub] [rocketmq] lizhimins opened a new pull request, #7310: [ISSUE #7308] Adding topic blacklist and filter to tiered storage module

2023-09-06 Thread via GitHub
lizhimins opened a new pull request, #7310: URL: https://github.com/apache/rocketmq/pull/7310 ### Which Issue(s) This PR Fixes Fixes #7308 ### Brief Description ### How Did You Test This Change? -- This is an automated message from

[GitHub] [rocketmq-client-go] oxcafebabe commented on issue #1041: the interface `rocketmq.Producer` can't be implemented outside

2023-09-06 Thread via GitHub
oxcafebabe commented on issue #1041: URL: https://github.com/apache/rocketmq-client-go/issues/1041#issuecomment-1708088499 using an internal type as an exported function's parameter is really a bad idea -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [rocketmq] lizhimins commented on a diff in pull request #7301: [ISSUE #7300] jRaft-Controller Implemention

2023-09-06 Thread via GitHub
lizhimins commented on code in PR #7301: URL: https://github.com/apache/rocketmq/pull/7301#discussion_r1316873289 ## remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java: ## @@ -275,13 +275,17 @@ public class RequestCode { * clean broker data

[GitHub] [rocketmq] codecov-commenter commented on pull request #7310: [ISSUE #7308] Adding topic blacklist and filter to tiered storage module

2023-09-06 Thread via GitHub
codecov-commenter commented on PR #7310: URL: https://github.com/apache/rocketmq/pull/7310#issuecomment-1708026013 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7310?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq] lizhimins merged pull request #7307: [ISSUE #7305] Fix metrics and transactional module not shutdown while broker offline cause coredump

2023-09-06 Thread via GitHub
lizhimins merged PR #7307: URL: https://github.com/apache/rocketmq/pull/7307 -- 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] [rocketmq] lizhimins closed issue #7305: [Bug] Fix metrics and transactional not shutdown cause broker coredump

2023-09-06 Thread via GitHub
lizhimins closed issue #7305: [Bug] Fix metrics and transactional not shutdown cause broker coredump URL: https://github.com/apache/rocketmq/issues/7305 -- 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

[GitHub] [rocketmq-eventbridge] 2011shenlin merged pull request #150: fix api destination update

2023-09-05 Thread via GitHub
2011shenlin merged PR #150: URL: https://github.com/apache/rocketmq-eventbridge/pull/150 -- 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] [rocketmq] yuz10 opened a new issue, #7295: [Enhancement] Reserve time for next retrial when send message.

2023-09-05 Thread via GitHub
yuz10 opened a new issue, #7295: URL: https://github.com/apache/rocketmq/issues/7295 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Normally, when one broker

[GitHub] [rocketmq] drpmma opened a new issue, #7296: [Enhancement] Add go-away mechanism for rocketmq-client

2023-09-05 Thread via GitHub
drpmma opened a new issue, #7296: URL: https://github.com/apache/rocketmq/issues/7296 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Add `go-away` mechanism

[GitHub] [rocketmq-spring] mufengCc commented on issue #556: 使用RocketMQMessageListener订阅多个topic的问题

2023-09-04 Thread via GitHub
mufengCc commented on issue #556: URL: https://github.com/apache/rocketmq-spring/issues/556#issuecomment-1705836905 ![image](https://github.com/apache/rocketmq-spring/assets/48708389/fbba1322-4632-4474-ae45-b7c02612d707)

[GitHub] [rocketmq] RongtongJin closed issue #7292: jna--934747322/jna13951917643251975730.tmp, 0x0001): tried: '/private/var/folders/nv/z8ncdq6n6ngf1nqfsq4hrkk80000gn/T/jna--934747322/jna139519176432

2023-09-05 Thread via GitHub
RongtongJin closed issue #7292: jna--934747322/jna13951917643251975730.tmp, 0x0001): tried: '/private/var/folders/nv/z8ncdq6n6ngf1nqfsq4hrkk8gn/T/jna--934747322/jna13951917643251975730.tmp' (fat file, but missing compatible architecture (have 'i386,x86_64', need 'arm64e')) URL:

[GitHub] [rocketmq-eventbridge] zhaohai666 opened a new pull request, #150: fix api destination update

2023-09-04 Thread via GitHub
zhaohai666 opened a new pull request, #150: URL: https://github.com/apache/rocketmq-eventbridge/pull/150 (no comment) -- 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] [rocketmq] Guohaonan1 opened a new issue, #7292: jna--934747322/jna13951917643251975730.tmp, 0x0001): tried: '/private/var/folders/nv/z8ncdq6n6ngf1nqfsq4hrkk80000gn/T/jna--934747322/jna139519

2023-09-04 Thread via GitHub
Guohaonan1 opened a new issue, #7292: URL: https://github.com/apache/rocketmq/issues/7292 ### 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]

[GitHub] [rocketmq-spring] yinyuncan commented on pull request #541: [ISSUE #539] Feat: support SpringBoot 3.x

2023-09-05 Thread via GitHub
yinyuncan commented on PR #541: URL: https://github.com/apache/rocketmq-spring/pull/541#issuecomment-1706016490 大家如果在升级到spring boot 3的时候遇到该问题,直接使用@Import(RocketMQAutoConfiguration.class) 配置即可 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [rocketmq-flink] SOD-DOB opened a new issue, #100: Run on k8s, it's throw RemotingTimeoutException

2023-09-05 Thread via GitHub
SOD-DOB opened a new issue, #100: URL: https://github.com/apache/rocketmq-flink/issues/100 my Flink Job run on k8s with flink-kubernetes-operator [https://github.com/apache/flink-kubernetes-operator]([flink-kubernetes-operator](flink-kubernetes-operator) Tasks always report errors

[GitHub] [rocketmq] zekai-li commented on pull request #6811: [ISSUE #6808] Fixed network bugs and merged networkutil code

2023-09-05 Thread via GitHub
zekai-li commented on PR #6811: URL: https://github.com/apache/rocketmq/pull/6811#issuecomment-1706029001 @RongtongJin Please check 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 to go to the

[GitHub] [rocketmq] zooah212 commented on issue #7187: [Bug] RocketMQ consumer消费不到第一条消息

2023-09-05 Thread via GitHub
zooah212 commented on issue #7187: URL: https://github.com/apache/rocketmq/issues/7187#issuecomment-1706208664 > 还真的是。我也复现这个问题了。 同样的5.1.3版本 嗯。当在高可用场景下,会出现更严重的问题。如果有两个 master A 和 B,当发消息的时候会随机在某个 master 上面创建 topic,比如在 master A 上面创建好了 topic,之后发/收消息会正常;但是当 master A 挂掉之后,再发消息则 Producer

[GitHub] [rocketmq] fengmk2 commented on issue #5728: Proxy ReceiveMessage the response data is "null. NullPointerException. org.apache.rocketmq.proxy.grpc.v2.consumer.ReceiveMessageActivity.receiveMe

2023-09-04 Thread via GitHub
fengmk2 commented on issue #5728: URL: https://github.com/apache/rocketmq/issues/5728#issuecomment-1705881991 should set grpc deadline options on receiveMessage to avoid "java.lang.NullPointerException: null" -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [rocketmq] RongtongJin opened a new pull request, #7294: [ISSUE #7293] Fix NPE when alter sync state set

2023-09-05 Thread via GitHub
RongtongJin opened a new pull request, #7294: URL: https://github.com/apache/rocketmq/pull/7294 ### Which Issue(s) This PR Fixes Fixes #7293 ### Brief Description Fix NPE when alter sync state set ### How Did You Test This Change?

[GitHub] [rocketmq] RongtongJin opened a new issue, #7293: [Enhancement] Throw NPE in alter sync state set

2023-09-05 Thread via GitHub
RongtongJin opened a new issue, #7293: URL: https://github.com/apache/rocketmq/issues/7293 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary NPE report when

[GitHub] [rocketmq] RongtongJin opened a new pull request, #7317: Add the configuration of topicQueueLock number to better support different queue nums scenarios

2023-09-06 Thread via GitHub
RongtongJin opened a new pull request, #7317: URL: https://github.com/apache/rocketmq/pull/7317 ### Which Issue(s) This PR Fixes Fixes #issue_id ### Brief Description ### How Did You Test This Change? -- This is an automated message

[GitHub] [rocketmq] codecov-commenter commented on pull request #7320: [ISSUE #7319] Optimize fault-tolerant mechanism for sending messages and hot update switch

2023-09-06 Thread via GitHub
codecov-commenter commented on PR #7320: URL: https://github.com/apache/rocketmq/pull/7320#issuecomment-1709413151 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7320?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq] github-actions[bot] closed issue #4945: Adjust the storedir format of test cases to the Windows platform

2023-09-06 Thread via GitHub
github-actions[bot] closed issue #4945: Adjust the storedir format of test cases to the Windows platform URL: https://github.com/apache/rocketmq/issues/4945 -- 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

[GitHub] [rocketmq] github-actions[bot] commented on pull request #4562: UpdateTopicRouteInfoFromNameServer method in the concurrent lack of detection

2023-09-06 Thread via GitHub
github-actions[bot] commented on PR #4562: URL: https://github.com/apache/rocketmq/pull/4562#issuecomment-1709279435 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,

[GitHub] [rocketmq] github-actions[bot] commented on issue #4945: Adjust the storedir format of test cases to the Windows platform

2023-09-06 Thread via GitHub
github-actions[bot] commented on issue #4945: URL: https://github.com/apache/rocketmq/issues/4945#issuecomment-1709279389 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

[GitHub] [rocketmq-apis] lizhanhui commented on issue #68: Why Producer not support send messages for batch

2023-09-06 Thread via GitHub
lizhanhui commented on issue #68: URL: https://github.com/apache/rocketmq-apis/issues/68#issuecomment-1709423623 @sycoral Protocol Buffers are not designed to handle large messages. See https://protobuf.dev/programming-guides/techniques/#large-data We should consider adding streaming

[GitHub] [rocketmq-apis] fanlunyong commented on issue #68: Why Producer not support send messages for batch

2023-09-06 Thread via GitHub
fanlunyong commented on issue #68: URL: https://github.com/apache/rocketmq-apis/issues/68#issuecomment-1709423900 这是来自QQ邮箱的自动回复邮件。   您好,请您放心您的邮件我已经收到。我将在看过邮件后,尽快给您回复。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [rocketmq] drpmma opened a new pull request, #7322: [ISSUE #7321] Refector NettyRemotingAbstract with unify future implementation

2023-09-07 Thread via GitHub
drpmma opened a new pull request, #7322: URL: https://github.com/apache/rocketmq/pull/7322 ### Which Issue(s) This PR Fixes Fixes #7321 ### Brief Description Provide unify future implementation Add operationSuccess and operationException for

[GitHub] [rocketmq] codecov-commenter commented on pull request #7317: [ISSUE #7318] Add the configuration of topicQueueLock number to better support different queue nums scenarios

2023-09-06 Thread via GitHub
codecov-commenter commented on PR #7317: URL: https://github.com/apache/rocketmq/pull/7317#issuecomment-1709403348 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7317?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq-exporter] drivebyer commented on pull request #94: [ISSUE #93]Optimize the grafana dashboard.

2023-09-07 Thread via GitHub
drivebyer commented on PR #94: URL: https://github.com/apache/rocketmq-exporter/pull/94#issuecomment-1709563882 @ShannonDing Could you merge 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 to go to

[GitHub] [rocketmq] GenerousMan opened a new issue, #7319: [Enhancement] Optimize fault-tolerant mechanism for sending messages and hot update switch

2023-09-06 Thread via GitHub
GenerousMan opened a new issue, #7319: URL: https://github.com/apache/rocketmq/issues/7319 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Optimize

[GitHub] [rocketmq] xdkxlk commented on a diff in pull request #7320: [ISSUE #7319] Optimize fault-tolerant mechanism for sending messages and hot update switch

2023-09-07 Thread via GitHub
xdkxlk commented on code in PR #7320: URL: https://github.com/apache/rocketmq/pull/7320#discussion_r1318164831 ## client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java: ## @@ -37,6 +37,8 @@ public class LatencyFaultToleranceImpl implements

[GitHub] [rocketmq] drpmma opened a new issue, #7321: [Enhancement] [ISSUE #7296] [TASK 1] Refector NettyRemotingAbstract with unify future implementation.

2023-09-07 Thread via GitHub
drpmma opened a new issue, #7321: URL: https://github.com/apache/rocketmq/issues/7321 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary This issue is a sub task

[GitHub] [rocketmq] RongtongJin opened a new issue, #7318: [Enhancement] Add the configuration of topicQueueLock number to better support different topic nums scenarios

2023-09-06 Thread via GitHub
RongtongJin opened a new issue, #7318: URL: https://github.com/apache/rocketmq/issues/7318 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Add the

[GitHub] [rocketmq] github-actions[bot] closed issue #4966: Optimize ThreadLocalIndex

2023-09-06 Thread via GitHub
github-actions[bot] closed issue #4966: Optimize ThreadLocalIndex URL: https://github.com/apache/rocketmq/issues/4966 -- 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] [rocketmq] github-actions[bot] commented on pull request #4957: [ISSUE #4945] Adjust the storedir format of test cases to the Windows platform

2023-09-06 Thread via GitHub
github-actions[bot] commented on PR #4957: URL: https://github.com/apache/rocketmq/pull/4957#issuecomment-1709279334 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,

[GitHub] [rocketmq] github-actions[bot] commented on issue #4949: Fix 'Address already in use' in AutoSwitchRoleIntegrationTest#testCheckSyncStateSet

2023-09-06 Thread via GitHub
github-actions[bot] commented on issue #4949: URL: https://github.com/apache/rocketmq/issues/4949#issuecomment-1709279363 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

[GitHub] [rocketmq] github-actions[bot] commented on pull request #4603: [ISSUE #4587] rocketmq thread pool add a "bottom-up" scheme to catch exceptions

2023-09-06 Thread via GitHub
github-actions[bot] commented on PR #4603: URL: https://github.com/apache/rocketmq/pull/4603#issuecomment-1709279403 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,

[GitHub] [rocketmq] github-actions[bot] closed issue #4949: Fix 'Address already in use' in AutoSwitchRoleIntegrationTest#testCheckSyncStateSet

2023-09-06 Thread via GitHub
github-actions[bot] closed issue #4949: Fix 'Address already in use' in AutoSwitchRoleIntegrationTest#testCheckSyncStateSet URL: https://github.com/apache/rocketmq/issues/4949 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [rocketmq-client-go] xiaolibuzai-ovo commented on issue #1007: Trace topic's routeInfoData can never be updated

2023-09-10 Thread via GitHub
xiaolibuzai-ovo commented on issue #1007: URL: https://github.com/apache/rocketmq-client-go/issues/1007#issuecomment-1712830954 hi,您好,我尝试修复了这个bug,辛苦review,第一次参与该项目有不规范的地方请指出 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [rocketmq-client-go] xiaolibuzai-ovo opened a new pull request, #1093: [ISSUE https://github.com/apache/rocketmq-client-go/issues/1007] fix trace use producer instead client

2023-09-10 Thread via GitHub
xiaolibuzai-ovo opened a new pull request, #1093: URL: https://github.com/apache/rocketmq-client-go/pull/1093 ## What is the purpose of the change For trace topic, initialize a real producer to send message instead of calling invokeSync directly at the communication layer [ISSUE

[GitHub] [rocketmq] Ziy1-Tan opened a new issue, #7334: [Enhancement] registerIncrementBrokerData for single topic update

2023-09-10 Thread via GitHub
Ziy1-Tan opened a new issue, #7334: URL: https://github.com/apache/rocketmq/issues/7334 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary There is no need to

[GitHub] [rocketmq] Ziy1-Tan opened a new pull request, #7335: [ISSUE #7334]registerIncrementBrokerData for single topic update

2023-09-10 Thread via GitHub
Ziy1-Tan opened a new pull request, #7335: URL: https://github.com/apache/rocketmq/pull/7335 ### Which Issue(s) This PR Fixes Fixes #7334 ### Brief Description ### How Did You Test This Change? -- This is an automated message from

[GitHub] [rocketmq] codecov-commenter commented on pull request #7335: [ISSUE #7334]registerIncrementBrokerData for single topic update

2023-09-10 Thread via GitHub
codecov-commenter commented on PR #7335: URL: https://github.com/apache/rocketmq/pull/7335#issuecomment-1712847351 ## [Codecov](https://app.codecov.io/gh/apache/rocketmq/pull/7335?src=pr=h1_medium=referral_source=github_content=comment_campaign=pr+comments_term=apache) Report > Merging

[GitHub] [rocketmq] shirenchuang opened a new issue, #7337: [Enhancement] The execution interval of cleanExpireMsgExecutors is too long

2023-09-10 Thread via GitHub
shirenchuang opened a new issue, #7337: URL: https://github.com/apache/rocketmq/issues/7337 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary

[GitHub] [rocketmq] RongtongJin closed issue #7334: [Enhancement] `registerIncrementBrokerData` for single topic update

2023-09-11 Thread via GitHub
RongtongJin closed issue #7334: [Enhancement] `registerIncrementBrokerData` for single topic update URL: https://github.com/apache/rocketmq/issues/7334 -- 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

[GitHub] [rocketmq] RongtongJin merged pull request #7335: [ISSUE #7334] `registerIncrementBrokerData` for single topic update

2023-09-11 Thread via GitHub
RongtongJin merged PR #7335: URL: https://github.com/apache/rocketmq/pull/7335 -- 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] [rocketmq-client-go] xiaolibuzai-ovo commented on issue #1007: Trace topic's routeInfoData can never be updated

2023-09-10 Thread via GitHub
xiaolibuzai-ovo commented on issue #1007: URL: https://github.com/apache/rocketmq-client-go/issues/1007#issuecomment-1713035975 > > > 我发现路由自动更新的逻辑是有的, 可以试试是否生效。 主要的处理过程如下: > > > > > > 1. 初始化rmqClient,维护一个producerMap, > > >

[GitHub] [rocketmq] RongtongJin merged pull request #7329: [ISSUE #7328] Convergent thread pool creation

2023-09-10 Thread via GitHub
RongtongJin merged PR #7329: URL: https://github.com/apache/rocketmq/pull/7329 -- 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] [rocketmq] RongtongJin closed issue #7328: [Enhancement] Convergent thread pool creation

2023-09-10 Thread via GitHub
RongtongJin closed issue #7328: [Enhancement] Convergent thread pool creation URL: https://github.com/apache/rocketmq/issues/7328 -- 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

[GitHub] [rocketmq] yuz10 opened a new issue, #7338: [Bug] Tiered store shutdown blocked

2023-09-11 Thread via GitHub
yuz10 opened a new issue, #7338: URL: https://github.com/apache/rocketmq/issues/7338 ### 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

  1   2   3   4   5   6   7   8   9   10   >