[jira] [Updated] (ROCKETMQ-108) Add username and password to RemotingCommand to support access control in broker

2017-02-21 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-108: Summary: Add username and password to RemotingCommand to support access control in broker (was:

[jira] [Updated] (ROCKETMQ-102) When shutdown(), the persisted offfet is not the latest consumed message, which may cause repeated messages

2017-02-15 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-102: Summary: When shutdown(), the persisted offfet is not the latest consumed message, which may

[jira] [Updated] (ROCKETMQ-102) Offet Persisted is not the latest consumed message, which may cause repeated messages

2017-02-15 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-102: Summary: Offet Persisted is not the latest consumed message, which may cause repeated messages

[jira] [Created] (ROCKETMQ-102) Offet Persisted is not the latest consumed message

2017-02-15 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-102: --- Summary: Offet Persisted is not the latest consumed message Key: ROCKETMQ-102 URL: https://issues.apache.org/jira/browse/ROCKETMQ-102 Project: Apache RocketMQ

[jira] [Created] (ROCKETMQ-109) View BrokerStats may result in ClassCastException when using store plugin

2017-02-21 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-109: --- Summary: View BrokerStats may result in ClassCastException when using store plugin Key: ROCKETMQ-109 URL: https://issues.apache.org/jira/browse/ROCKETMQ-109 Project:

[jira] [Updated] (ROCKETMQ-105) Implementation of consumerOffset and maxOffset are counter-intuitive

2017-02-16 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-105: Description: This issue does not affect any functionality=ies, but it indeed is a problem for

[jira] [Updated] (ROCKETMQ-105) Implementation of consumerOffset and maxOffset are counter-intuitive

2017-02-16 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-105: Description: This issue does not affect any functionality=ies, but it indeed is a problem for

[jira] [Updated] (ROCKETMQ-110) consumeConcurrentlyMaxSpan has a very limited role

2017-02-23 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-110: Description: Actually, in the current implementation of consumeConcurrentlyMaxSpan , the role

[jira] [Created] (ROCKETMQ-110) consumeConcurrentlyMaxSpan has a very limited role

2017-02-23 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-110: --- Summary: consumeConcurrentlyMaxSpan has a very limited role Key: ROCKETMQ-110 URL: https://issues.apache.org/jira/browse/ROCKETMQ-110 Project: Apache RocketMQ

[jira] [Assigned] (ROCKETMQ-107) Access ServiceState is not thread safe when start() or shutdown()

2017-02-21 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-107: --- Assignee: Jaskey Lam (was: Xiaorui Wang) > Access ServiceState is not thread safe when

[jira] [Assigned] (ROCKETMQ-106) Add flow control on topic level

2017-02-21 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-106: --- Assignee: Jaskey Lam (was: Xiaorui Wang) > Add flow control on topic level >

[jira] [Assigned] (ROCKETMQ-67) Consistent Hash allocate strategy support

2017-02-21 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-67?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-67: -- Assignee: Jaskey Lam (was: Xiaorui Wang) > Consistent Hash allocate strategy support >

[jira] [Assigned] (ROCKETMQ-96) Rename tmp variable

2017-02-21 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-96?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-96: -- Assignee: Jaskey Lam (was: Xiaorui Wang) > Rename tmp variable > > >

[jira] [Assigned] (ROCKETMQ-98) Risk of unable to release putMessage Lock forever

2017-02-21 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-98?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-98: -- Assignee: Jaskey Lam (was: vongosling) > Risk of unable to release putMessage Lock forever >

[jira] [Updated] (ROCKETMQ-97) SendCallback should bring response code and extMessags in OnException

2017-02-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-97?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-97: --- Description: For sendAsync, when excpetion occurs, the developer will have nothing to distiguish

[jira] [Comment Edited] (ROCKETMQ-92) Having all consumer/producer configurations in one place

2017-02-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-92?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865216#comment-15865216 ] Jaskey Lam edited comment on ROCKETMQ-92 at 2/14/17 6:57 AM: - I implemented

[jira] [Created] (ROCKETMQ-96) Rename tmp variable

2017-02-13 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-96: -- Summary: Rename tmp variable Key: ROCKETMQ-96 URL: https://issues.apache.org/jira/browse/ROCKETMQ-96 Project: Apache RocketMQ Issue Type: Improvement

[jira] [Updated] (ROCKETMQ-96) Rename tmp variable

2017-02-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-96?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-96: --- Description: Some variable is named with tmp which is very difficult to read and understand its

[jira] [Updated] (ROCKETMQ-97) SendCallback should bring response code and extMessags in OnException

2017-02-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-97?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-97: --- Description: For sendAsync, when excpetion occurs, the developer will have nothing to distiguish

[jira] [Created] (ROCKETMQ-97) SendCallback should bring response code and extMessags in OnException

2017-02-13 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-97: -- Summary: SendCallback should bring response code and extMessags in OnException Key: ROCKETMQ-97 URL: https://issues.apache.org/jira/browse/ROCKETMQ-97 Project: Apache

[jira] [Created] (ROCKETMQ-98) Risk of unable to release putMessage Lock forever

2017-02-14 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-98: -- Summary: Risk of unable to release putMessage Lock forever Key: ROCKETMQ-98 URL: https://issues.apache.org/jira/browse/ROCKETMQ-98 Project: Apache RocketMQ

[jira] [Created] (ROCKETMQ-100) checkTransactionState is not implemented in broker

2017-02-14 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-100: --- Summary: checkTransactionState is not implemented in broker Key: ROCKETMQ-100 URL: https://issues.apache.org/jira/browse/ROCKETMQ-100 Project: Apache RocketMQ

[jira] [Created] (ROCKETMQ-101) Possible NullPointerException when retry in send Async way

2017-02-15 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-101: --- Summary: Possible NullPointerException when retry in send Async way Key: ROCKETMQ-101 URL: https://issues.apache.org/jira/browse/ROCKETMQ-101 Project: Apache RocketMQ

[jira] [Created] (ROCKETMQ-105) Implementation of consumerOffset and maxOffset are counter-intuitive

2017-02-16 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-105: --- Summary: Implementation of consumerOffset and maxOffset are counter-intuitive Key: ROCKETMQ-105 URL: https://issues.apache.org/jira/browse/ROCKETMQ-105 Project: Apache

[jira] [Updated] (ROCKETMQ-101) Possible NullPointerException when retry in send Async way

2017-02-16 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-101: Description: When retry async send, possible NPE will occure:

[jira] [Updated] (ROCKETMQ-105) Implementation of consumerOffset and maxOffset are counter-intuitive

2017-02-16 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-105: Description: This issue does not affect all functionality, but it indeed is a problem for user

[jira] [Updated] (ROCKETMQ-101) Possible NullPointerException when retry in send Async way

2017-02-16 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-101: Description: When retry async send, possible NPE will occure: ```

[jira] [Updated] (ROCKETMQ-100) checkTransactionState is not implemented in broker

2017-02-15 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-100: Issue Type: Improvement (was: New Feature) > checkTransactionState is not implemented in broker

[jira] [Created] (ROCKETMQ-94) Support different subscriptions for some newly release instance

2017-02-13 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-94: -- Summary: Support different subscriptions for some newly release instance Key: ROCKETMQ-94 URL: https://issues.apache.org/jira/browse/ROCKETMQ-94 Project: Apache RocketMQ

[jira] [Updated] (ROCKETMQ-94) Support different subscriptions for some newly release instance

2017-02-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-94?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-94: --- Description: RocketMQ 's consumer group has a restrict that all instances must have the same

[jira] [Updated] (ROCKETMQ-94) Support different subscriptions for some newly release instance

2017-02-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-94?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-94: --- Description: RocketMQ 's consumer group has a restrict that all instances must have the same

[jira] [Updated] (ROCKETMQ-94) Support different subscriptions for some newly release instance

2017-02-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-94?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-94: --- Description: RocketMQ 's consumer group has a restrict that all instances must have the same

[jira] [Updated] (ROCKETMQ-67) Consistent Hash allocate strategy support

2017-01-19 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-67?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-67: --- Description: For now, the average allocate strategy is very sensitive when clients register and

[jira] [Comment Edited] (ROCKETMQ-112) MQ client CONSUME_FROM_LAST_OFFSET dont work

2017-02-28 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889595#comment-15889595 ] Jaskey Lam edited comment on ROCKETMQ-112 at 3/1/17 6:37 AM: - [~zhaoziyan]

[jira] [Commented] (ROCKETMQ-112) MQ client CONSUME_FROM_LAST_OFFSET dont work

2017-02-28 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889595#comment-15889595 ] Jaskey Lam commented on ROCKETMQ-112: - [~zhaoziyan] please reformat your comment accroing to

[jira] [Comment Edited] (ROCKETMQ-112) MQ client CONSUME_FROM_LAST_OFFSET dont work

2017-02-28 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889595#comment-15889595 ] Jaskey Lam edited comment on ROCKETMQ-112 at 3/1/17 6:30 AM: - [~zhaoziyan]

[jira] [Updated] (ROCKETMQ-40) AUTO_CLIENT_ACKNOWNLEDGE & CLIENT_ACKNOWLEDGE support

2017-01-10 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-40?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-40: --- Description: For now, push consumer only supports DUPS_OK_ACKNOWLEDGE . If user wants to

[jira] [Created] (ROCKETMQ-40) AUTO_CLIENT_ACKNOWNLEDGE & CLIENT_ACKNOWLEDGE support

2017-01-10 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-40: -- Summary: AUTO_CLIENT_ACKNOWNLEDGE & CLIENT_ACKNOWLEDGE support Key: ROCKETMQ-40 URL: https://issues.apache.org/jira/browse/ROCKETMQ-40 Project: Apache RocketMQ

[jira] [Updated] (ROCKETMQ-40) AUTO_CLIENT_ACKNOWNLEDGE & CLIENT_ACKNOWLEDGE support

2017-01-10 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-40?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-40: --- Description: For now, push consumer only supports DUPS_OK_ACKNOWLEDGE . If user wants to

[jira] [Created] (ROCKETMQ-14) Remoting invoke callback shoule be invoked in an executor rather than in current thread.

2016-12-25 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-14: -- Summary: Remoting invoke callback shoule be invoked in an executor rather than in current thread. Key: ROCKETMQ-14 URL: https://issues.apache.org/jira/browse/ROCKETMQ-14

[jira] [Created] (ROCKETMQ-158) Remove logback dependency for rocketmq-tools

2017-03-28 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-158: --- Summary: Remove logback dependency for rocketmq-tools Key: ROCKETMQ-158 URL: https://issues.apache.org/jira/browse/ROCKETMQ-158 Project: Apache RocketMQ Issue

[jira] [Comment Edited] (ROCKETMQ-145) Hit ConcurrentModificationException in doWaitTransfer which happens very offen

2017-03-19 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932100#comment-15932100 ] Jaskey Lam edited comment on ROCKETMQ-145 at 3/20/17 2:59 AM: -- [~Yukon]

[jira] [Comment Edited] (ROCKETMQ-145) Hit ConcurrentModificationException in doWaitTransfer which happens very offen

2017-03-19 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932100#comment-15932100 ] Jaskey Lam edited comment on ROCKETMQ-145 at 3/20/17 3:00 AM: -- [~Yukon]

[jira] [Comment Edited] (ROCKETMQ-145) Hit ConcurrentModificationException in doWaitTransfer which happens very offen

2017-03-19 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932100#comment-15932100 ] Jaskey Lam edited comment on ROCKETMQ-145 at 3/20/17 3:01 AM: -- [~Yukon]

[jira] [Commented] (ROCKETMQ-146) Hit "port out of range:" in decodeMessageId happens sometimes

2017-03-20 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15932535#comment-15932535 ] Jaskey Lam commented on ROCKETMQ-146: - In current version, the message pass to consumeMessage is

[jira] [Created] (ROCKETMQ-160) SendHeartBeart log may not be triggered in the same expected period

2017-04-01 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-160: --- Summary: SendHeartBeart log may not be triggered in the same expected period Key: ROCKETMQ-160 URL: https://issues.apache.org/jira/browse/ROCKETMQ-160 Project: Apache

[jira] [Comment Edited] (ROCKETMQ-169) Support flow control when slave restarts and replicating from master

2017-04-12 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965784#comment-15965784 ] Jaskey Lam edited comment on ROCKETMQ-169 at 4/12/17 12:57 PM: --- I think

[jira] [Commented] (ROCKETMQ-169) Support flow control when slave restarts and replicating from master

2017-04-12 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965784#comment-15965784 ] Jaskey Lam commented on ROCKETMQ-169: - I think this is an important and beneficial feature, since if

[jira] [Comment Edited] (ROCKETMQ-169) Support flow control when slave restarts and replicating from master

2017-04-12 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965784#comment-15965784 ] Jaskey Lam edited comment on ROCKETMQ-169 at 4/12/17 12:58 PM: --- I think

[jira] [Comment Edited] (ROCKETMQ-169) Support flow control when slave restarts and replicating from master

2017-04-12 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965784#comment-15965784 ] Jaskey Lam edited comment on ROCKETMQ-169 at 4/12/17 12:59 PM: --- I think

[jira] [Created] (ROCKETMQ-173) Add comment to HA code base

2017-04-12 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-173: --- Summary: Add comment to HA code base Key: ROCKETMQ-173 URL: https://issues.apache.org/jira/browse/ROCKETMQ-173 Project: Apache RocketMQ Issue Type:

[jira] [Updated] (ROCKETMQ-173) Add comment to HA code base

2017-04-12 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-173: Description: The HA service is the very crucial part for rocketmq and the code base is hard to

[jira] [Comment Edited] (ROCKETMQ-163) DefaultMQPullConsumer.java批量拉取消息最大只能拉800个

2017-04-12 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965860#comment-15965860 ] Jaskey Lam edited comment on ROCKETMQ-163 at 4/12/17 1:38 PM: -- Please

[jira] [Comment Edited] (ROCKETMQ-169) Support flow control when slave restarts and replicating from master

2017-04-12 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965784#comment-15965784 ] Jaskey Lam edited comment on ROCKETMQ-169 at 4/12/17 1:09 PM: -- I think this

[jira] [Assigned] (ROCKETMQ-172) log improvement for rocketmq client

2017-04-11 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-172: --- Assignee: Jaskey Lam (was: Xiaorui Wang) > log improvement for rocketmq client >

[jira] [Created] (ROCKETMQ-180) CONSUME_FROM_TIMESTAMP will repeat the last message though timestamp is new enough

2017-04-17 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-180: --- Summary: CONSUME_FROM_TIMESTAMP will repeat the last message though timestamp is new enough Key: ROCKETMQ-180 URL: https://issues.apache.org/jira/browse/ROCKETMQ-180

[jira] [Updated] (ROCKETMQ-180) CONSUME_FROM_TIMESTAMP will repeat the last message though timestamp is new enough

2017-04-17 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-180: Description: When using CONSUME_FROM_TIMESTAMP , rocketmq will try to search latest offset and

[jira] [Updated] (ROCKETMQ-105) Implementation of consumerOffset and maxOffset are counter-intuitive

2017-04-17 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-105: Description: This issue does not affect any functionalites, but it indeed is a problem for user

[jira] [Updated] (ROCKETMQ-105) Implementation of consumerOffset and maxOffset are counter-intuitive

2017-04-17 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-105: Description: This issue does not affect any functionalites, but it indeed is a problem for user

[jira] [Updated] (ROCKETMQ-105) Implementation of consumerOffset and maxOffset are counter-intuitive

2017-04-17 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-105: Description: This issue does not affect any functionalites, but it indeed is a problem for user

[jira] [Comment Edited] (ROCKETMQ-94) Support different subscriptions for some newly release instance

2017-04-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-94?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15968566#comment-15968566 ] Jaskey Lam edited comment on ROCKETMQ-94 at 4/14/17 3:45 AM: -

[jira] [Updated] (ROCKETMQ-94) Support different subscriptions for some newly release instance

2017-04-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-94?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-94: --- Description: RocketMQ 's consumer group has a restrict that all instances must have the same

[jira] [Commented] (ROCKETMQ-94) Support different subscriptions for some newly release instance

2017-04-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-94?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15968566#comment-15968566 ] Jaskey Lam commented on ROCKETMQ-94: [~Yukon][~vongosling] What's the plan for this problem? This

[jira] [Commented] (ROCKETMQ-175) Consumer may miss messages because of inconsistent subscription

2017-04-13 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15968563#comment-15968563 ] Jaskey Lam commented on ROCKETMQ-175: - This is not a bug, every client should be have exactly the

[jira] [Created] (ROCKETMQ-138) Add AuthenticationException class to remove hard coded Aliyun authentication class

2017-03-10 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-138: --- Summary: Add AuthenticationException class to remove hard coded Aliyun authentication class Key: ROCKETMQ-138 URL: https://issues.apache.org/jira/browse/ROCKETMQ-138

[jira] [Updated] (ROCKETMQ-138) Add AuthenticationException class to remove hard coded Aliyun authentication class

2017-03-10 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-138: Priority: Minor (was: Major) Issue Type: Improvement (was: Bug) > Add

[jira] [Updated] (ROCKETMQ-136) Provide a handy message queue selector for order message sharding

2017-03-09 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-136: Description: When order message is needed, users need to provide a message queue selector to

[jira] [Updated] (ROCKETMQ-136) Provide a handy message queue selector for order message shading

2017-03-09 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-136: Summary: Provide a handy message queue selector for order message shading (was: Provide a handy

[jira] [Commented] (ROCKETMQ-123) Support distributed transaction messaging

2017-03-09 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15902706#comment-15902706 ] Jaskey Lam commented on ROCKETMQ-123: - An old issue has been created for this:

[jira] [Updated] (ROCKETMQ-184) It takes too long(3-33 seconds) to switch to read from slave when master crashes

2017-04-19 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-184: Description: When master crashes, no notifier callback has been triggered to pull message again.

[jira] [Created] (ROCKETMQ-184) It takes too long(3-33 seconds) to switch to read from slave when master crashes

2017-04-19 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-184: --- Summary: It takes too long(3-33 seconds) to switch to read from slave when master crashes Key: ROCKETMQ-184 URL: https://issues.apache.org/jira/browse/ROCKETMQ-184

[jira] [Updated] (ROCKETMQ-184) It takes too long(3-33 seconds) to switch to read from slave when master crashes

2017-04-19 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-184: Description: When master crashes, no notifier callback is triggered to pull message again.

[jira] [Updated] (ROCKETMQ-136) Provide a handy message queue producer for order message sharding

2017-08-17 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-136: Summary: Provide a handy message queue producer for order message sharding (was: Provide a handy

[jira] [Updated] (ROCKETMQ-250) fix fetchNSAddr error when it refer to jmenv.tbsite.net

2017-07-27 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-250: Description: *strong text*jmenv.tbsite.net may can not be reached in inner envirment when find

[jira] [Updated] (ROCKETMQ-250) fix fetchNSAddr error when it refer to jmenv.tbsite.net

2017-07-27 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-250: Description: *strong text*jmenv.tbsite.net may can not be reached in inner envirment when find

[jira] [Commented] (ROCKETMQ-245) All topic msg put in the same log may is not a good desgin .

2017-07-26 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101299#comment-16101299 ] Jaskey Lam commented on ROCKETMQ-245: - I am afraid this design is with careful consideration, which

[jira] [Comment Edited] (ROCKETMQ-242) mqclient can not fetch nameSrvAddr periodly

2017-07-26 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101292#comment-16101292 ] Jaskey Lam edited comment on ROCKETMQ-242 at 7/26/17 7:53 AM: -- The issue

[jira] [Commented] (ROCKETMQ-248) ConsumeFromWhere does not always work as expected

2017-07-26 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16101302#comment-16101302 ] Jaskey Lam commented on ROCKETMQ-248: - Indeed, it will not work when the queue is newly created.

[jira] [Created] (ROCKETMQ-188) RemotingExecption is not consistent between invoke async and invoke oneway

2017-04-24 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-188: --- Summary: RemotingExecption is not consistent between invoke async and invoke oneway Key: ROCKETMQ-188 URL: https://issues.apache.org/jira/browse/ROCKETMQ-188 Project:

[jira] [Assigned] (ROCKETMQ-200) Cluster name is always missing when fetch ClusterInfo from name server

2017-05-17 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-200: --- Assignee: Jaskey Lam (was: Xiaorui Wang) > Cluster name is always missing when fetch

[jira] [Created] (ROCKETMQ-200) Cluster name is always missing when fetch ClusterInfo from name server

2017-05-17 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-200: --- Summary: Cluster name is always missing when fetch ClusterInfo from name server Key: ROCKETMQ-200 URL: https://issues.apache.org/jira/browse/ROCKETMQ-200 Project:

[jira] [Created] (ROCKETMQ-203) Support client to allocate message q in machine room nearby priority

2017-05-24 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-203: --- Summary: Support client to allocate message q in machine room nearby priority Key: ROCKETMQ-203 URL: https://issues.apache.org/jira/browse/ROCKETMQ-203 Project: Apache

[jira] [Commented] (ROCKETMQ-67) Consistent Hash allocate strategy support

2017-05-28 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-67?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16028049#comment-16028049 ] Jaskey Lam commented on ROCKETMQ-67: i wonder why this issue is marked as fixed and closed? is the

[jira] [Updated] (ROCKETMQ-203) Support client to allocate message qUEUE in machine room nearby priority

2017-05-31 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-203: Summary: Support client to allocate message qUEUE in machine room nearby priority (was: Support

[jira] [Updated] (ROCKETMQ-203) Support client to allocate message queue in machine room nearby priority

2017-05-31 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-203: Summary: Support client to allocate message queue in machine room nearby priority (was: Support

[jira] [Commented] (ROCKETMQ-208) incompatibility problem found in enviroment of JDK 1.7 when running client

2017-06-02 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16034634#comment-16034634 ] Jaskey Lam commented on ROCKETMQ-208: - Since the problem is found in 3.5.8, and I have checked that

[jira] [Updated] (ROCKETMQ-208) incompatibility problem found in enviroment of JDK 1.7 when running client

2017-06-02 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-208: Issue Type: Bug (was: Wish) > incompatibility problem found in enviroment of JDK 1.7 when

[jira] [Commented] (ROCKETMQ-208) incompatibility problem found in enviroment of JDK 1.7 when running client

2017-06-02 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16034600#comment-16034600 ] Jaskey Lam commented on ROCKETMQ-208: - Some methods calls `keySet()` in rocketmq code base, and the

[jira] [Commented] (ROCKETMQ-204) all brokers were down but client still report heartbeat

2017-06-06 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16040106#comment-16040106 ] Jaskey Lam commented on ROCKETMQ-204: - The problem is because when update topic route info from

[jira] [Assigned] (ROCKETMQ-204) when all brokers is offline, client still attempts to send heartbeat

2017-06-07 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-204: --- Assignee: Jaskey Lam (was: yukon) > when all brokers is offline, client still attempts to

[jira] [Commented] (ROCKETMQ-210) Logic Error in ConsumeMessageOrderlyService#checkReconsumeTimes

2017-06-07 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16040325#comment-16040325 ] Jaskey Lam commented on ROCKETMQ-210: - No I don't think it's buggy. This method is to check if it

[jira] [Comment Edited] (ROCKETMQ-210) Logic Error in ConsumeMessageOrderlyService#checkReconsumeTimes

2017-06-07 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16040325#comment-16040325 ] Jaskey Lam edited comment on ROCKETMQ-210 at 6/7/17 6:56 AM: - No I don't

[jira] [Comment Edited] (ROCKETMQ-204) all brokers were down but client still report heartbeat

2017-06-06 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16040106#comment-16040106 ] Jaskey Lam edited comment on ROCKETMQ-204 at 6/7/17 3:38 AM: - The problem is

[jira] [Updated] (ROCKETMQ-215) Use java 7 syntax to refator code base

2017-06-07 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-215: Description: code base may have some code like {code} private ConcurrentMap> offsetTable =

[jira] [Assigned] (ROCKETMQ-208) incompatibility problem found in enviroment of JDK 1.7 when running client

2017-06-05 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam reassigned ROCKETMQ-208: --- Assignee: Jaskey Lam (was: yukon) > incompatibility problem found in enviroment of JDK

[jira] [Updated] (ROCKETMQ-208) incompatibility problem found in enviroment of JDK 1.7 when running client

2017-06-05 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-208: Component/s: (was: rocketmq-broker) rocketmq-client > incompatibility

[jira] [Created] (ROCKETMQ-214) Improvement to help client to switch balance strategy

2017-06-05 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-214: --- Summary: Improvement to help client to switch balance strategy Key: ROCKETMQ-214 URL: https://issues.apache.org/jira/browse/ROCKETMQ-214 Project: Apache RocketMQ

[jira] [Updated] (ROCKETMQ-214) Improvement to help client to switch balance strategy smoothly

2017-06-05 Thread Jaskey Lam (JIRA)
[ https://issues.apache.org/jira/browse/ROCKETMQ-214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaskey Lam updated ROCKETMQ-214: Summary: Improvement to help client to switch balance strategy smoothly (was: Improvement to

[jira] [Created] (ROCKETMQ-223) Rename DEFAULT_TOPIC

2017-06-13 Thread Jaskey Lam (JIRA)
Jaskey Lam created ROCKETMQ-223: --- Summary: Rename DEFAULT_TOPIC Key: ROCKETMQ-223 URL: https://issues.apache.org/jira/browse/ROCKETMQ-223 Project: Apache RocketMQ Issue Type: Improvement