Re: Regarding: Request to help in code walkthrough

Hi Srinath Thota: First of all, I'm so sorry for the late response to your attentions I think you can start by building and compiling it, write down your initial feelings and discuss them together, and we will have a consensus on the changes:https://tubemq.apache.org/en-us/ Thanks! Srinath Thot

[jira] [Resolved] (TUBEMQ-407) Fix some content in README.md

[ https://issues.apache.org/jira/browse/TUBEMQ-407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang resolved TUBEMQ-407. --- Fix Version/s: 0.7.0 Resolution: Fixed > Fix some content in README.md > -

[jira] [Resolved] (TUBEMQ-379) Modify the memory cache size default to 3M

[ https://issues.apache.org/jira/browse/TUBEMQ-379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang resolved TUBEMQ-379. --- Fix Version/s: 0.7.0 Resolution: Fixed > Modify the memory cache size default to 3M >

[jira] [Assigned] (TUBEMQ-379) Modify the memory cache size default to 3M

[ https://issues.apache.org/jira/browse/TUBEMQ-379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-379: - Assignee: Guocheng Zhang > Modify the memory cache size default to 3M >

[jira] [Commented] (TUBEMQ-419) SetMaxPartCheckPeriodMs() negative number, getMessage() still lock the thread

[ https://issues.apache.org/jira/browse/TUBEMQ-419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237138#comment-17237138 ] ASF subversion and git services commented on TUBEMQ-419: Commit 3

[jira] [Updated] (TUBEMQ-344) Add broker receiving time in message property

[ https://issues.apache.org/jira/browse/TUBEMQ-344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-344: -- Summary: Add broker receiving time in message property (was: 在Message属性中增加broker接收时间) > Add b

[jira] [Commented] (TUBEMQ-344) 在Message属性中增加broker接收时间

[ https://issues.apache.org/jira/browse/TUBEMQ-344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237098#comment-17237098 ] Guocheng Zhang commented on TUBEMQ-344: --- I got'it. In addition to this problem, ba

[jira] [Updated] (TUBEMQ-344) 在Message属性中增加broker接收时间

[ https://issues.apache.org/jira/browse/TUBEMQ-344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-344: -- Description: When using the offset setting function of tube, there is a problem that there is

[jira] [Assigned] (TUBEMQ-414) add rest api for consumer group operation

[ https://issues.apache.org/jira/browse/TUBEMQ-414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-414: - Assignee: Yuanbo Liu > add rest api for consumer group operation > -

[jira] [Assigned] (TUBEMQ-344) 在Message属性中增加broker接收时间

[ https://issues.apache.org/jira/browse/TUBEMQ-344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-344: - Assignee: Guocheng Zhang > 在Message属性中增加broker接收时间 > --- > >

[jira] [Commented] (TUBEMQ-418) C++ SDK function SetMaxPartCheckPeriodMs() can't work

[ https://issues.apache.org/jira/browse/TUBEMQ-418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237092#comment-17237092 ] Guocheng Zhang commented on TUBEMQ-418: --- Thanks! [~h-j-13] (y) > C++ SDK function

[jira] [Updated] (TUBEMQ-418) C++ SDK function SetMaxPartCheckPeriodMs() can't work

[ https://issues.apache.org/jira/browse/TUBEMQ-418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-418: -- Fix Version/s: 0.7.0 > C++ SDK function SetMaxPartCheckPeriodMs() can't work > --

[jira] [Resolved] (TUBEMQ-418) C++ SDK function SetMaxPartCheckPeriodMs() can't work

[ https://issues.apache.org/jira/browse/TUBEMQ-418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang resolved TUBEMQ-418. --- Resolution: Fixed > C++ SDK function SetMaxPartCheckPeriodMs() can't work > ---

[jira] [Assigned] (TUBEMQ-403) support broker list/reload/delete/add operations by rest api

[ https://issues.apache.org/jira/browse/TUBEMQ-403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-403: - Assignee: Yuanbo Liu > support broker list/reload/delete/add operations by rest api > --

[jira] [Assigned] (TUBEMQ-404) support master switch by rest api

[ https://issues.apache.org/jira/browse/TUBEMQ-404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-404: - Assignee: Yuanbo Liu > support master switch by rest api > -

[jira] [Assigned] (TUBEMQ-360) Add configuration classes for manager project

[ https://issues.apache.org/jira/browse/TUBEMQ-360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-360: - Assignee: Yuanbo Liu > Add configuration classes for manager project > -

[jira] [Assigned] (TUBEMQ-346) remove chinese comments

[ https://issues.apache.org/jira/browse/TUBEMQ-346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-346: - Assignee: Yuanbo Liu > remove chinese comments > --- > >

[jira] [Assigned] (TUBEMQ-343) merge tubeMQ-manager to Apache TubeMQ as a module

[ https://issues.apache.org/jira/browse/TUBEMQ-343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-343: - Assignee: Yuanbo Liu > merge tubeMQ-manager to Apache TubeMQ as a module > -

[jira] [Assigned] (TUBEMQ-337) rest api for tubeMQ manager

[ https://issues.apache.org/jira/browse/TUBEMQ-337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-337: - Assignee: Yuanbo Liu > rest api for tubeMQ manager > --- > >

[jira] [Assigned] (TUBEMQ-339) cluster manager for tubeMQ cluster

[ https://issues.apache.org/jira/browse/TUBEMQ-339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-339: - Assignee: Yuanbo Liu > cluster manager for tubeMQ cluster >

[jira] [Assigned] (TUBEMQ-387) add manager web pages

[ https://issues.apache.org/jira/browse/TUBEMQ-387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-387: - Assignee: Yuanbo Liu > add manager web pages > - > >

[jira] [Assigned] (TUBEMQ-338) web pages for tubemq manager

[ https://issues.apache.org/jira/browse/TUBEMQ-338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-338: - Assignee: Yuanbo Liu > web pages for tubemq manager > > >

[jira] [Commented] (TUBEMQ-418) C++ SDK function SetMaxPartCheckPeriodMs() can't work

[ https://issues.apache.org/jira/browse/TUBEMQ-418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237089#comment-17237089 ] houjie commented on TUBEMQ-418: --- Great! it fixed.  When I updated the SDK, SetMaxPartCheckP

[jira] [Assigned] (TUBEMQ-413) update pom.xml to pack project

[ https://issues.apache.org/jira/browse/TUBEMQ-413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-413: - Assignee: Yuanbo Liu > update pom.xml to pack project > -- >

[jira] [Updated] (TUBEMQ-418) C++ SDK function SetMaxPartCheckPeriodMs() can't work

[ https://issues.apache.org/jira/browse/TUBEMQ-418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] houjie updated TUBEMQ-418: -- Attachment: (was: sf.png) > C++ SDK function SetMaxPartCheckPeriodMs() can't work > -

[jira] [Updated] (TUBEMQ-418) C++ SDK function SetMaxPartCheckPeriodMs() can't work

[ https://issues.apache.org/jira/browse/TUBEMQ-418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] houjie updated TUBEMQ-418: -- Attachment: sf.png > C++ SDK function SetMaxPartCheckPeriodMs() can't work >

[jira] [Updated] (TUBEMQ-418) C++ SDK function SetMaxPartCheckPeriodMs() can't work

[ https://issues.apache.org/jira/browse/TUBEMQ-418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] houjie updated TUBEMQ-418: -- Attachment: sf.png > C++ SDK function SetMaxPartCheckPeriodMs() can't work >

[jira] [Assigned] (TUBEMQ-412) tube manager start stop scrrpts

[ https://issues.apache.org/jira/browse/TUBEMQ-412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-412: - Assignee: Yuanbo Liu > tube manager start stop scrrpts > ---

[jira] [Updated] (TUBEMQ-115) Support cross-cluster production and consumption scheduling

[ https://issues.apache.org/jira/browse/TUBEMQ-115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-115: -- Fix Version/s: (was: 0.7.0) > Support cross-cluster production and consumption scheduling >

[jira] [Updated] (TUBEMQ-116) Support load balancing customization

[ https://issues.apache.org/jira/browse/TUBEMQ-116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-116: -- Fix Version/s: (was: 0.7.0) > Support load balancing customization > --

[jira] [Updated] (TUBEMQ-111) Improve filter performance and increase the number of concurrent filters

[ https://issues.apache.org/jira/browse/TUBEMQ-111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-111: -- Fix Version/s: (was: 0.7.0) > Improve filter performance and increase the number of concurr

[jira] [Updated] (TUBEMQ-114) Support consumers to adjust consumption targets without restarting

[ https://issues.apache.org/jira/browse/TUBEMQ-114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-114: -- Fix Version/s: (was: 0.7.0) > Support consumers to adjust consumption targets without resta

[jira] [Updated] (TUBEMQ-113) Improve the consumption control ability of the client

[ https://issues.apache.org/jira/browse/TUBEMQ-113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-113: -- Fix Version/s: (was: 0.7.0) > Improve the consumption control ability of the client > -

[jira] [Updated] (TUBEMQ-110) Optimize Broker storage to increase throughput

[ https://issues.apache.org/jira/browse/TUBEMQ-110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-110: -- Fix Version/s: (was: 0.7.0) > Optimize Broker storage to increase throughput >

[jira] [Updated] (TUBEMQ-72) Support Kafka Compatible Protocol in TubeMQ

[ https://issues.apache.org/jira/browse/TUBEMQ-72?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-72: - Fix Version/s: (was: 0.7.0) > Support Kafka Compatible Protocol in TubeMQ > --

[jira] [Updated] (TUBEMQ-118) Provide MQ upstream and downstream supporting capabilities

[ https://issues.apache.org/jira/browse/TUBEMQ-118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-118: -- Fix Version/s: (was: 0.7.0) 0.8.0 > Provide MQ upstream and downstream s

[jira] [Updated] (TUBEMQ-120) Aligned disk data storage

[ https://issues.apache.org/jira/browse/TUBEMQ-120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang updated TUBEMQ-120: -- Fix Version/s: (was: 0.7.0) > Aligned disk data storage > - > >

[jira] [Resolved] (TUBEMQ-419) SetMaxPartCheckPeriodMs() negative number, getMessage() still lock the thread

[ https://issues.apache.org/jira/browse/TUBEMQ-419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang resolved TUBEMQ-419. --- Fix Version/s: 0.7.0 Resolution: Fixed > SetMaxPartCheckPeriodMs() negative number, g

[jira] [Assigned] (TUBEMQ-419) SetMaxPartCheckPeriodMs() negative number, getMessage() still lock the thread

[ https://issues.apache.org/jira/browse/TUBEMQ-419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guocheng Zhang reassigned TUBEMQ-419: - Assignee: Guocheng Zhang > SetMaxPartCheckPeriodMs() negative number, getMessage() stil

[jira] [Updated] (TUBEMQ-406) test_consumer.py works for both Python 2 and 3

[ https://issues.apache.org/jira/browse/TUBEMQ-406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-406: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > test_consumer.py works

[jira] [Updated] (TUBEMQ-405) python sdk install files lack of the whole cpp configuration

[ https://issues.apache.org/jira/browse/TUBEMQ-405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-405: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > python sdk install file

[jira] [Updated] (TUBEMQ-410) install python package and simplify test_consumer.py

[ https://issues.apache.org/jira/browse/TUBEMQ-410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-410: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > install python package

[jira] [Updated] (TUBEMQ-399) expose C++ SDK method by Pybind11

[ https://issues.apache.org/jira/browse/TUBEMQ-399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-399: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > expose C++ SDK method b

[jira] [Updated] (TUBEMQ-401) python sdk readme bug

[ https://issues.apache.org/jira/browse/TUBEMQ-401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-401: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > python sdk readme bug >

[jira] [Updated] (TUBEMQ-400) add example for consume message by bypind11

[ https://issues.apache.org/jira/browse/TUBEMQ-400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-400: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > add example for consume

[jira] [Updated] (TUBEMQ-398) reinit project for using pybind11

[ https://issues.apache.org/jira/browse/TUBEMQ-398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-398: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > reinit project for usin

[jira] [Updated] (TUBEMQ-383) document about Installation/API Reference/Example

[ https://issues.apache.org/jira/browse/TUBEMQ-383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-383: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > document about Installa

[jira] [Updated] (TUBEMQ-276) add python client encode/decode protobuf message for TubeMQ RPC Protocol

[ https://issues.apache.org/jira/browse/TUBEMQ-276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charles Zhang updated TUBEMQ-276: - Fix Version/s: (was: tubemq-client-python) 0.7.0 > add python client encod