Re: Re: [VOTE] Release Apache RocketMQ-MQTT 1.0.1

2023-02-24 Thread Xin Wang 
+1

jinrongtong  于2023年2月24日周五 18:06写道：

> +1, I Checked[OK]  verify the asc(PGP sign),SHA512[OK]  maven
> jar in nexus repo is right[OK] Hash and Tag in GitHub repo is matching
> the current artifactsIn addition, it would be better to update
> year to 2023 in source package's notice file in next release.
> At 2023-02-24 15:02:45, "Qingshan Lin"  wrote:
> >good job. The capabilities of MQTT are getting richer。
> >+1
> >
> >On 2023/02/24 03:29:08 Ping Wang wrote:
> >> Hello RocketMQ Community,
> >>
> >> This is the vote for 1.0.1 of Apache RocketMQ-MQTT.
> >>
> >> This version adds support for the two features WILL and RETAIN, and
> >> introduces the META module.
> >>
> >> The artifacts:
> >> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-mqtt/
> >>
> >> The staging repo:
> >>
> https://repository.apache.org/content/repositories/orgapacherocketmq-1133/
> >>
> >> Git tag for the release:
> >>
> https://github.com/apache/rocketmq-mqtt/releases/tag/rocketmq-mqtt-1.0.1
> >>
> >> Hash for the release tag:
> >> 9eefd0901454e3fbf36344e0f725b8d28f65e26f
> >>
> >> The artifacts have been signed with Key :
> >> D8B0E224FC82CC6782B7F09FEFAD557E48236FB9, which can be found in the keys
> >> file:  https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
> >>
> >> Checklist for reference,
> >> Note that this is not an official policy but may help with checking
> >> releases.
> >>
> >> Fill in the following:
> >> [ ]  check LICENSE, should be Apache V2
> >> [ ]  check NOTICE, should have a notice for third-party dependency if
> >> necessary
> >> [ ]  extract the zip and check if the source version is correct
> >> [ ]  verify the asc(PGP sign),SHA512
> >>
> >> The vote will be open for at least 72 hours or until the necessary
> number
> >> of votes are reached.
> >> Please vote accordingly:
> >>
> >> [ ] +1 approve
> >>
> >> [ ] +0 no opinion
> >>
> >> [ ] -1 disapprove with the reason
> >>
> >> Thanks
> >> The Apache RocketMQ Team
> >>
>


-- 
Thanks,
Xin

Re: [VOTE]: Release Apache RocketMQ 5.1.0 RC1

2023-02-19 Thread Xin Wang 
+1

Zhanhui Li  于2023年2月18日周六 22:37写道：

> +1
>
> Verified checksum, signature.
>
> On Sat, Feb 18, 2023 at 2:12 PM Xinyu Zhou  wrote:
>
> > +1 Big features are introduced since this release. Thanks to all the
> > contributors.
> >
> > By the way, your key has been copied to the release KEYS file for your
> next
> > steps as a release manager.
> >
> >
> > On Fri, Feb 17, 2023 at 6:42 PM SSpirits  wrote:
> >
> > > ＋1
> > >
> > > Your response would be highly appreciated.
> > > SSpirits
> > > Email：ad...@lv5.moe
> > > 在 2023年2月17日+0800 PM6:34，Qiang Wang ，写道：
> > > +1 binding
> > >
> > > 1. Compiling passed
> > > 2. asc checked.
> > > 3. shasum exists
> > > 4. version correct.
> > >
> > > Good luck.
> > >
> > > jinrongtong  于2023年2月17日周五 17:55写道：
> > >
> > > +1, I Checked[OK] verify the asc(PGP sign),SHA512[OK] maven
> > > jar in nexus repo is right
> > > At 2023-02-17 17:28:38, "Zhouxiang Zhan"  wrote:
> > > Hello RocketMQ Community,
> > >
> > >
> > > This is the vote for 5.1.0 RC1 of Apache RocketMQ.
> > >
> > >
> > > This release contains some important new features, including supporting
> > > remoting protocol in proxy, transaction message improvement, tiered
> > > storage
> > > and etc.
> > >
> > >
> > > *The artifacts:*
> > >
> > > https://dist.apache.org/repos/dist/dev/rocketmq/5.1.0-rc1
> > >
> > >
> > > *The staging repo:*
> > >
> > >
> > >
> > >
> >
> https://repository.apache.org/content/repositories/orgapacherocketmq-1148/org/apache/rocketmq/
> > >
> > >
> > > *Git tag for the release:*
> > >
> > > https://github.com/apache/rocketmq/tree/rocketmq-all-5.1.0
> > >
> > >
> > > *Hash for the release tag:*
> > >
> > > b8e9334d2a1ed8868a3b15b63b8ef3198fcb81ce
> > >
> > >
> > > *Release Notes:*
> > >
> > > https://rocketmq.apache.org/release-notes/2023/02/16/5.1.0/
> > >
> > >
> > > The artifacts have been signed with
> > > Key 8213C5B0D057B71E4DFD41806688AEA6B96540B2 which can be found in the
> > > keys file:
> > >
> > > https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
> > >
> > >
> > > The vote will be open for at least 72 hours or until necessary number
> of
> > > votes are reached.
> > >
> > >
> > > Please vote accordingly:
> > >
> > > [ ] +1 approve
> > >
> > > [ ] +0 no opinion
> > >
> > > [ ] -1 disapprove with the reason
> > >
> > >
> > > Thanks,
> > >
> > > The Apache RocketMQ Team
> > >
> > >
> >
>


-- 
Thanks,
Xin

Re: [vote]: Release RocketMQ Streams 1.1.1

2023-02-19 Thread Xin Wang 
+1

nize  于2023年2月18日周六 19:37写道：

> Hi all, The Apache RocketMQ team would like to announce the release of
> RocketMQ Streams 1.1.1
>
> RocketMQ Streams is a lightweight stream processing framework, application
> gains the stream processing ability by depending on RocketMQ Streams as an
> SDK.
>
>
> The artifacts:
> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-streams/1.1.1/
>
> The staging repo:
> https://repository.apache.org/content/repositories/orgapacherocketmq-1140/
>
> Git tag for the release:
> https://github.com/apache/rocketmq-streams/releases
>
> Hash for the release tag:
>
> 7b85a1817da712a69a75a16a2a08eff10b73baba
>
>
> Relate Notes:
>
> https://github.com/apache/rocketmq-streams/releases
>
>
> The artifacts have been signed with Key :
>
> C15E0A9888919CC8A2F7EBB0268C587BB6345D14,which can be found in the keys
>
> file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
>
>
> Fill in the following:
>
> [ ]  check LICENSE, should be Apache V2
>
> [ ]  check NOTICE, should have a notice for third-party dependency if
> necessary
>
> [ ]  extract the zip and check if the source version is correct
>
> [ ]  verify the asc(PGP sign),SHA512
>
> [ ] build the source, start rocketmq schema registry server according to
> the quick-start
>
>
> The vote will be open for at least 72 hours or until the necessary number
> of votes are reached.
>
> Please vote accordingly:
>


-- 
Thanks,
Xin

Re: [DISCUSS] Prepare to release RocketMQ Streams 1.1.1

2023-02-14 Thread Xin Wang 
+1 Nice work. Thanks nize for managing the release.


nize  于2023年2月14日周二 16:59写道：

> Hello RocketMQ Community,
>
> This is the discussion for the release of Rocketmq Streams 1.1.1 version.
>
> RocketMQ Streams is a lightweight stream processing framework, application
> gains the stream processing ability by depending on RocketMQ Streams as an
> SDK.
>
>
> In this release, capabilities are supported as follows：
>
>
>1.
>
>support avg function in WindowStream
>2.
>
>use the name of thread as rocksdb path and clean the temporary data of
>rocksdb in local when shutdown;
>3.
>
>keep state topic type consistent with source topic;
>4.
>
> add a configuration to trigger the idle window;
>5.
>
>other bug fix and polish;
>
>
> If there are no other sounds, I would like to call for a vote for RocketMQ
> Streams 1.1.1 release.
>


-- 
Thanks,
Xin

Re: Re:Re: [DISCUSS] Prepare to release Apache RocketMQ 5.0.1

2023-02-09 Thread Xin Wang 
Great. Thanks, Zhouxiang for managing the release.

Xinyu Zhou  于2023年2月10日周五 10:32写道：

> +1
>
> Thanks for volunteering for this release.
>
> On Thu, Feb 9, 2023 at 6:16 PM 643422162 <643422...@qq.com> wrote:
>
> > +1
> >
> >
> > -- 原始邮件 --
> > *发件人: *"jinrongtong";
> > *发件时间: *2023-02-09 16:10
> > *收件人: *"dev";
> > *收件人: *
> >
> > "users";
> > *主题: *Re:Re: [DISCUSS] Prepare to release Apache RocketMQ 5.0.1
> >
> >
> > +1
> > At 2023-02-09 16:04:54, "aaron ai" wrote:
> > >+1, Nice to see it moving forward after the release of 5.0.0
> > >
> > >Zhouxiang Zhan 于2023年2月9日周四 14:23写道：
> > >
> > >> Hi, RocketMQ community:
> > >>
> > >> I'd like to propose releasing Apache RocketMQ 5.0.1. It's been a while
> > >> since RocketMQ 5.0.0 was released.During this time, multiple important
> > >> features were merged into the code trunk, including remoting protocol
> > >> proxy[
> > >> 1], observability improvement[2], server-side offset management[3],
> > >> remoting module improvement[4], transaction message[5], pop orderly
> > >> improvement[6], backporting of remoting client[7], logging module with
> > >> shaded logback[8], tiered storage[9], etc.We also did some stability
> and
> > >> bug fixes on the trunk. It's time to release RocketMQ 5.0.1. I would
> > like
> > >> to start an email thread to discuss the plan.
> > >>
> > >> If you have any important bug fixes or questions, please reply to this
> > >> email.
> > >>
> > >> Regards，
> > >> Zhouxiang Zhan
> > >>
> > >>
> > >>
> > >> [1]
> > >>
> > >>
> >
> https://github.com/apache/rocketmq/wiki/RIP-55-Support-remoting-protocol-in-rocketmq-proxy-module
> > >> [2]
> > >>
> > >>
> >
> https://github.com/apache/rocketmq/wiki/RIP-46-Observability-improvement-for-RocketMQ
> > >> [3]
> > >>
> > >>
> >
> https://github.com/apache/rocketmq/wiki/RIP-48-Enhance-server-side-offset-management-ability
> > >> [4]
> > >>
> > >>
> >
> https://github.com/apache/rocketmq/wiki/RIP-49-RocketMQ-remoting-module-improvement
> > >> [5]
> > >>
> > >>
> >
> https://github.com/apache/rocketmq/wiki/RIP-50-RocketMQ-Transaction-Message-Improvement
> > >> [6]
> > https://github.com/apache/rocketmq/wiki/RIP-51-Pop-orderly-improvement
> > >> [7]
> > >>
> > >>
> >
> https://github.com/apache/rocketmq/wiki/RIP-54-Backporting-of-Remoting-based-Client
> > >> [8]
> > >>
> > >>
> >
> https://github.com/apache/rocketmq/wiki/RIP-56-Replace-Logging-Module-with-Shaded-Logback
> > >> [9]
> > >>
> >
> https://github.com/apache/rocketmq/wiki/RIP-57-Tiered-storage-for-RocketMQ
> > >>
> >
>


-- 
Thanks,
Xin

Re: [DISCUSS] [RIP-61] RocketMQ EventBridge Runtime

2023-01-30 Thread Xin Wang 
+1 Nick work. Thanks shenlin.

Xinyu Zhou  于2023年1月29日周日 22:34写道：

> +1 to start this RIP.
>
> In most cases, users need an embedded and stateless runtime to adopt
> eventbridge in a single-tenant scenario.
> For large-scale use cases, the rocketmq-connect runtime is another option.
>
> Regards,
> yukon
>
> On Fri, Jan 27, 2023 at 5:16 PM 沈林 <2011shen...@gmail.com> wrote:
>
> > Hello RocketMQ Community:
> >
> > We have plans to add Runtime to EventBridge to reduce the dependence on
> > external services and improve the service experience of EDA integration.
> >
> > We have written the proposal, and you can see it by the link below:
> > https://github.com/apache/rocketmq-eventbridge/wiki/EventBridge-Runtime
> >
> > Please reply to this email if you have any suggestions.
> >
> > Your response would be highly appreciated.
> >
>


-- 
Thanks,
Xin

Re: [DISCUSS] Release RocketMQ Streams 1.1.0

2023-01-04 Thread Xin Wang 
+1 Thanks for the nice work.

nize  于2023年1月3日周二 17:22写道：

> Hello RocketMQ Community,
>
> This is the discussion for the release of Rocketmq Streams 1.1.0 version.
>
> RocketMQ Streams is a lightweight stream processing framework, application
> gains the stream processing ability by depending on RocketMQ Streams as an
> SDK.
>
>
> In this release, capabilities are supported as follows：
>
>
>1. A new stream processing task construction process.
>2. Removes  the configurable module and makes code more clear.
>3. Support custom serialization and deserialization.
>4. A new stream processing process, unify the source and shuffle.
>
>
> If there are no other sounds, I would like to call for a vote for RocketMQ
> Streams 1.1.0 release.
>


-- 
Thanks,
Xin

Re: [VOTE] Release gRPC Java Client for Apache RocketMQ 5.0.4 RC1

2022-12-16 Thread Xin Wang 
+1

Qingshan Lin  于2022年12月16日周五 10:25写道：

> +1
>
> On 2022/12/15 02:51:00 lollipop wrote:
> > +1
> >
> > On Tue, Dec 13, 2022 at 11:36 AM aaron ai  wrote:
> >
> > > Hello RocketMQ Community,
> > >
> > >
> > > This is the vote for 5.0.4 RC1 of Apache RocketMQ client for java.
> > >
> > >
> > > Apache RocketMQ clients 5.x series follow the specs of rocketmq-apis
> > > , and are built on top of
> > > Protocol
> > > Buffer and gRPC.
> > >
> > >
> > > The artifact:
> > >
> > >
> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.0.4-rc1/
> > > <
> > >
> https://dist.apache.org/repos/dist/dev/rocketmq/rocketmq-clients/rocketmq-client-java/5.0.4-rc1/
> > > >
> > >
> > >
> > > The staging repo for maven:
> > >
> > >
> https://repository.apache.org/content/repositories/orgapacherocketmq-1130/
> > > <
> > >
> https://repository.apache.org/content/repositories/orgapacherocketmq-1130/
> > > >
> > >
> > >
> > > Git tag for the release:
> > > https://github.com/apache/rocketmq-clients/releases/tag/java-5.0.4
> > >
> > >
> > > Hash for the release tag: 33dfa2cebae9a2987f222c2563fd22103dc29588
> > >
> > >
> > > Relate Notes:
> > >  https://github.com/apache/rocketmq-clients/releases/tag/java-5.0.4
> > > 
> > >
> > >
> > > The artifacts have been signed with Key :
> > > 3A11FEBBD64C807A233BF1F27C46C79BD4D29011, which can be found in the
> keys
> > > file: https://dist.apache.org/repos/dist/dev/rocketmq/KEYS
> > >
> > >
> > > Fill in the following:
> > >
> > >
> > > [+]  check LICENSE, should be Apache V2
> > >
> > >
> > > [+]  check NOTICE, should have a notice for third-party dependency if
> > > necessary
> > >
> > >
> > > [+]  extract the zip and check if the source version is correct
> > >
> > >
> > > [+]  verify the asc(PGP sign),SHA512
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > > The vote will be open for at least 72 hours or until the necessary
> number
> > > of votes are reached.
> > >
> > >
> > > Please vote accordingly:
> > >
> > >
> > >
> > >
> > >
> > > [ ] +1 approve
> > >
> > >
> > > [ ] +0 no opinion
> > >
> > >
> > > [ ] -1 disapprove with the reason
> > >
> > >
> > >
> > >
> > >
> > > Thanks
> > >
> > >
> > > The Apache RocketMQ Team
> > >
> >
>


-- 
Thanks,
Xin

Re: [VOTE] [RIP-57] Tiered storage for RocketMQ

2022-12-14 Thread Xin Wang 
+1

nize  于2022年12月15日周四 14:24写道：

> +1
>
> Xinyu Zhou  于2022年12月15日周四 13:05写道：
>
> > +1
> >
> > On Thu, Dec 15, 2022 at 12:47 PM hzh0425  wrote:
> >
> > > ➕1
> > >
> > >
> > >
> > > | |
> > > hzh...@163.com
> > > |
> > > |
> > > 邮箱：hzh...@163.com
> > > |
> > >
> > >
> > >
> > >
> > >  回复的原邮件 
> > > | 发件人 | Zhouxiang Zhan |
> > > | 日期 | 2022年12月15日 11:03 |
> > > | 收件人 | dev@rocketmq.apache.org |
> > > | 抄送至 | |
> > > | 主题 | Re: [VOTE] [RIP-57] Tiered storage for RocketMQ |
> > > +1
> > >
> > > On Thu, Dec 15, 2022 at 10:59 AM 战忽局001号员工 
> > wrote:
> > >
> > > > +1
> > > >
> > > > > 2022年12月15日 10:52，SSpirits  写道：
> > > > >
> > > > > Hello RocketMQ Community,
> > > > >
> > > > > As discussed in the previous email, we discussed introducing tiered
> > > > storage for RocketMQ, and it's time to start an email thread to enter
> > the
> > > > voting process.
> > > > >
> > > > > Links:
> > > > >
> > > >
> > >
> >
> https://github.com/apache/rocketmq/wiki/RIP-57-Tiered-storage-for-RocketMQ
> > > > >
> > > > > The vote will be open for at least 72 hours or until the necessary
> > > > > number of votes are reached.
> > > > >
> > > > > Please vote accordingly:
> > > > > [ ] +1 approve
> > > > > [ ] +0 no opinion
> > > > > [ ] -1 disapprove with the reason
> > > > >
> > > > > Thanks
> > > > >
> > > > > Your response would be highly appreciated.
> > > > > SSpirits
> > > > > Email：ad...@lv5.moe
> > > >
> > > >
> > >
> >
>


-- 
Thanks,
Xin

Re: [DISCUSS] [RIP-57] Tiered storage for RocketMQ

2022-11-22 Thread Xin Wang 
Big +1 for this feature.

Xinyu Zhou  于2022年11月22日周二 17:57写道：

> +1 to leverage the ability of cloud storage through this RIP.
>
> On Tue, Nov 22, 2022 at 10:41 AM aaron ai  wrote:
>
> > Pleasant to see this feature since Pulsar/Kafka has provided similar
> > ability for tiered storage.
> >
> > SSpirits  于2022年11月21日周一 20:15写道：
> >
> > > Hi, RocketMQ Community：
> > >
> > > We have the plan to improve the store module of RocketMQ. Specifically,
> > we
> > > want to introduce tiered storage for RocketMQ to extend message reserve
> > > time and get other benefits.
> > >
> > > We have written the proposal, and you can see it by the link below:
> > >
> >
> https://github.com/apache/rocketmq/wiki/RIP-57-Tiered-storage-for-RocketMQ
> > >
> > > Please reply to this email if you have any suggestions.
> > >
> > > Your response would be highly appreciated.
> > > SSpirits
> > > Email：ad...@lv5.moe
> > >
> >
>


-- 
Thanks,
Xin

Re: [ANNOUNCE] Release gRPC Java Client for Apache RocketMQ 5.0.2

2022-11-09 Thread Xin Wang 
Great job! Team!

It would be better if the quickStart document*1 could be updated. There are
some bugs in previous versions(e.g. PushConsumerImpl NPE bug in 5.0.0).

**1 https://rocketmq.apache.org/docs/quickStart/02quickstart
*

aaron ai  于2022年10月9日周日 19:24写道：

> Hi all,
>
> The Apache RocketMQ team would like to announce the release of Apache
> RocketMQ gRPC Client 5.0.2.
>
> Apache RocketMQ clients 5.x series follow the specs of rocketmq-apis
> , and are built on top of
> Protocol Buffer and gRPC.
>
> The release artifacts can be downloaded here:
>
> https://dist.apache.org/repos/dist/release/rocketmq/rocketmq-clients/rocketmq-client-java/5.0.2/
>
> The release notes can be found here:
> https://github.com/apache/rocketmq-clients/releases/tag/java-5.0.2
>
> Thanks,
> The Apache RocketMQ Team
>


-- 
Thanks,
Xin

Re: Re: [ANNOUCE] New committer Jonnxu

2019-06-11 Thread Xin Wang 
Congrats!

huzongt...@cmss.chinamobile.com 
于2019年6月11日周二 下午1:38写道：

> Congrats！Jonnxu
> Best Regards,
>
> Best Regards,
> Zongtang Hu
>
>
> --
> huzongt...@cmss.chinamobile.com
>
>
> *From:* Gosling Von 
> *Date:* 2019-06-11 12:22
> *To:* users ; jonnxu 
> *CC:* dev ; private 
> *Subject:* Re: [ANNOUCE] New committer Jonnxu
> Congrats Jonnxu:-)
>
>
> Best Regards,
> Von Gosling
>
> > On Jun 11, 2019, at 9:22 AM, heng du  wrote:
> >
> > Hi Apache RocketMQ Community,
> >
> > The Project Management Committee (PMC) for Apache RocketMQ has invited
> Jonnxu(apache id: xujiang) to become a committer and we are pleased to
> announce that they have accepted. Congrats, guy :-)
> >
> > Notice: Being a committer enables easier contribution to the project
> since there is no need to go via the patch submission process. This should
> enable better productivity. and being a PMC member enables assistance with
> the management and to guide the direction of the project.
> >
> >
> > Best Regards,
> > Henry
>
>
>

-- 
Thanks,
Xin

Re: [ANNOUNCE] New committer and PMC member for Apache RocketMQ

2018-12-24 Thread Xin Wang 
Congrats Du & Ding !!

- Xin

Gosling Von  于2018年12月24日周一 下午4:40写道：

> Congrats, smart community guys I've worked with :-)
>
>
> Best Regards,
> Von Gosling
>
> 在 2018年12月24日，下午4:34，dongeforever  写道：
>
> Hi Apache RocketMQ Community,
>
> The Project Management Committee (PMC) for Apache RocketMQ has invited
> Heng Du(apache id: duhengforever) to become PMC Member and
> ShannonDing(apache id: dinglei) to become committer and we are pleased to
> announce that they have accepted.
>
> ShannonDing [1][2], who built a client eco-system for Apache RocketMQ
> Community. With his great work, the community has released a production
> ready client for CPP and Python. And also the Go Client is on the way.
>
> Heng Du [3], who spent much time in expanding the community. With his
> great work, ShannonDing is quickly familiar with Apache Way and doing a
> pretty job in contributing to the clients. At the same time, he has helped
> the community to release 4.3.2 and 4.3.1, and the rocketmq-spring 2.0.0.
>
> Congrats, guys :-)
>
> Notice: Being a committer enables easier contribution to the project since
> there is no need to go via the patch submission process. This should enable
> better productivity. and being a PMC member enables assistance with the
> management and to guide the direction of the project.
>
>
> [1]
> https://github.com/apache/rocketmq-client-cpp/pulls?q=is%3Apr+author%3AShannonDing
> [2]
> https://github.com/apache/rocketmq-client-python/pulls?q=is%3Apr+author%3AShannonDing
> [3]
> https://lists.apache.org/list.html?dev@rocketmq.apache.org:lte=3M:heng%20du
>
> Best Regards,
> Apache RocketMQ Team
>
>
>

-- 
Thanks,
Xin

Re: [STARTUP] Apache RocketMQ Meetup China - Shanghai

2018-12-19 Thread Xin Wang 
Hi devs,

I'd like to share a topic "OpenMessaging Stream & SQL API" in this meetup.
This topic includes:
* Challenges of stream computing: Past, Present and Future
* How to process stream events with existing MQ cluster
* The API design of OpenMessaging Stream & SQL API

Hope this is helpful to users processing stream data with MQ.

Thanks,
Xin

dongeforever  于2018年12月19日周三 下午2:28写道：

> Hi:
> I'd like to share a topic on "openmessage dledger", a raft-based
> implementation of openmessaging storage, which could act as the persistent
> layer of Apache RocketMQ.  With dledger, it's able to replace the old
> commitlog, and to failover automatically when some node crashes.
>
> Best Regards
> dongeforever
>
> Kevin Wang  于2018年12月19日周三 下午2:09写道：
>
>> It is a good opportunity to understand the new features from RocketMQ and
>> get to know more requirement form developers face to face. I am a developer
>> from RocketMQ. I would like to share the Topic "RocketMQ 101 + Spring Boot
>> RocketMQ”, which will introduce the basic usage of RocketMQ and SpringBoot
>> client develop process and experience.  Hope to become a speaker for the
>> meeting :-)
>>
>> Thanks,
>> Kevin/walking98
>>
>> 在 2018年12月18日，下午12:22，vongosling  写道：
>>
>> Dear Apache RocketMQ Community,
>>
>> I am excited to call for the Apache RocketMQ Meetup China, Shanghai at
>> Jan. 12, 2019 (Saturday). Please have a look at your schedule, and consider
>> submitting a talk to the community[1].  The overarching message about this
>> meetup is “Apache RocketMQ: Cloud-Native Data Processing Infrastructure“,
>> and we wish to highlight the fact that Apache RocketMQ is where tomorrow is
>> invented - you are the ones inventing it.
>>
>>
>> For further updated about this Meetup, follow us on Twitter,
>> @ApacheRocketMQ, or contact me - vongosl...@apache.org - with any
>> questions or concerns.
>>
>> [1] http://alibabadeveloper.mikecrm.com/SRR6nMH
>>
>> Best Regards,
>> Von Gosling
>>
>>
>>

Re: [STARTUP]Apache RocketMQ Beijing Meetup

2018-08-08 Thread Xin Wang 
Hi devs,

I'd like to share a topic, Streaming Processing with Apache RocketMQ, in
this meetup.
This topic includes:
* RocketMQ streaming ecosystem
* Streaming systems data fault-tolerant & How to build a connector between
MQ and streaming engine
* Integrating RocketMQ with streaming
system(Storm/Flink/Spark-Streaming/Spark2.x Structed-Streaming)
* Some of the practices and challenges in use
* A brief introduction for RocketMQ-SQL
Hope this is helpful to users processing stream data with RocketMQ.

Thanks,
Xin

2018-08-09 10:45 GMT+08:00 dongeforever :

> Dear Apache RocketMQ Community,
>
> I am excited to call for the second meetup in Beijing, China at Sep. 1 pm.,
> 2018. Please have a look at your schedule, and consider submitting a talk
> to the community, just reply to this email.
>
> The overarching message about this meetup is “Apache RocketMQ: Messaging
> and Streaming’s Technology Today“, and we wish to highlight the fact that
> Apache RocketMQ is where tomorrow is invented - you are the ones inventing
> it.
>
> For myself, I would like to share a topic `Apache RocketMQ Cookbook` in
> this meetup, hope this is helpful to users facing the similar scenario.
>
>
> For further updated about this Meetup, follow us on Twitter,
> @ApacheRocketMQ, with any question or concern.
>
>
> Best Regards,
> dongeforever
>

Re: [GSoC][ROCKETMQ-379][Support AMQP protocol for RocketMQ] Weekly meeting

2018-06-03 Thread Xin Wang 
Hi Sergio,

You can just follow your plan, starting the work for integrating RocketMQ
with HBase first. And you can take a look at the code for RocketMQ-Beam
after I commit it in the coming days.
I will sync the information in the rocketmq dev@ mailing-list.

Thanks,
- Xin

2018-05-30 3:29 GMT+08:00 Sergio Esteves :

> Hi Xin,
>
> Thanks a lot for reaching out to me. I started already studying the code
> and playing around with roquetmq, as well as seting up the repo for the
> hbase integration plugin.
>
> The integration plugin with beam was supposed to be the second part of my
> proposal but I would be happy to work first on that plugin with you. Can we
> synchronize on that via some instant messaging app (skype, whatsapp,
> google, or any other)?
>
> Thanks much!
>
>
> On Tue, May 29, 2018, 17:24 Xin Wang  wrote:
>
>> Hi Sergio,
>> I noticed you had a topic "Implementing integration plugins in RocketMQ
>> for HBase and Beam". What's the progress of the work?
>> Now I'm working on the RocketMQ-Beam integration almost completely. I
>> guess we can share something. And you can join me if your work hasn't
>> started. Let's work together.
>>
>> Thanks,
>> - Xin
>>
>> 2018-05-29 17:38 GMT+08:00 Von Gosling :
>>
>>> Hi Kasthuriraajan,
>>>
>>> Thanks for your conclusion, we could use the email to discuss the
>>> question more frequently :-)
>>>
>>> IMO, we could scope the implementation of the exchange type for AMQP
>>> firstly, direct and topic may be a better priority. Besides, I am wonder
>>> how to maintain the mapping relationship between AMQP and RocketMQ Message
>>> Model in your design, could you make it clear for me?
>>>
>>> Anyway,  I think design is the most significant, we must think again
>>> before we begin to code.
>>>
>>> Best Regards,
>>> Von Gosling
>>>
>>> > 在 2018年5月29日，16:01，Kasthuriraajan Ratnasingam <
>>> kasthuriraaja...@gmail.com> 写道：
>>> >
>>> > Hi all,
>>> >
>>> > First of all thank you so much for participating today's meeting. I'm
>>> so
>>> > sorry about troubles in my internet connection. (Today power cut in my
>>> > area, so no electricity I have contacted on mobile. That's why the
>>> > trouble.)  .I'll try to avoid this interruption in upcoming meetings.
>>> >
>>> > You can find the meeting notes below:
>>> >
>>> > 1) We have to use AMQP 0.9.1 because of it's wide usage.
>>> > 2)Our main focus is AMQP proxy server.
>>> > 3)The complete project plan and detailed design should be updated.
>>> >
>>> > People participated in hangouts: Von Gosling, Zhanhui Li, Heng du,
>>> > Kasthuriraajan.
>>> >
>>> > I'll update my detailed design of project soon in this mailing list.
>>> All of
>>> > my questions have cleared for now. If any questions arise during
>>> project
>>> > design, I'll ask in this mailing list.
>>> >
>>> > Thank you.
>>> >
>>> > Best Regards,
>>> > R.Kasthuriraajan.
>>> >
>>> > On Tue, May 29, 2018 at 11:51 AM, Von Gosling >> <mailto:vongosl...@apache.org>> wrote:
>>> >
>>> >> kindly ping Kasthuriraajan, are you online ？
>>> >>
>>> >> 在 2018年5月29日，14:05，Kasthuriraajan Ratnasingam <
>>> kasthuriraaja...@gmail.com>
>>> >> 写道：
>>> >>
>>> >> Hi Von,
>>> >>
>>> >> Kind reminder on today's meeting. I'm ready in hangouts.
>>> >>
>>> >> Thanks,
>>> >> R.Kasthuriraajan.
>>> >>
>>> >> On Mon, May 28, 2018 at 9:06 PM, Kasthuriraajan Ratnasingam <
>>> >> kasthuriraaja...@gmail.com> wrote:
>>> >>
>>> >>> Hi Von,
>>> >>>
>>> >>> Thank you for the reply.
>>> >>>
>>> >>> Yes we can meet through hangouts, tomorrow (29 ,May 2018) 2:00 pm
>>> GMT+8.
>>> >>> I have sent you an invitation to " *vongosl...@apache.org
>>> >>> <http://apache.org/ <http://apache.org/>> *" for google hangouts.
>>> >>>
>>> >>>
>>> >>>> I think the programme has started as GSoC schedule, Isn't it?
>>> >>>>
>>> >>> Yes. But I asked about our meeti

Re: [GSoC][ROCKETMQ-379][Support AMQP protocol for RocketMQ] Weekly meeting

2018-05-29 Thread Xin Wang 
Hi Sergio,
I noticed you had a topic "Implementing integration plugins in RocketMQ for
HBase and Beam". What's the progress of the work?
Now I'm working on the RocketMQ-Beam integration almost completely. I guess
we can share something. And you can join me if your work hasn't started.
Let's work together.

Thanks,
- Xin

2018-05-29 17:38 GMT+08:00 Von Gosling :

> Hi Kasthuriraajan,
>
> Thanks for your conclusion, we could use the email to discuss the question
> more frequently :-)
>
> IMO, we could scope the implementation of the exchange type for AMQP
> firstly, direct and topic may be a better priority. Besides, I am wonder
> how to maintain the mapping relationship between AMQP and RocketMQ Message
> Model in your design, could you make it clear for me?
>
> Anyway,  I think design is the most significant, we must think again
> before we begin to code.
>
> Best Regards,
> Von Gosling
>
> > 在 2018年5月29日，16:01，Kasthuriraajan Ratnasingam <
> kasthuriraaja...@gmail.com> 写道：
> >
> > Hi all,
> >
> > First of all thank you so much for participating today's meeting. I'm so
> > sorry about troubles in my internet connection. (Today power cut in my
> > area, so no electricity I have contacted on mobile. That's why the
> > trouble.)  .I'll try to avoid this interruption in upcoming meetings.
> >
> > You can find the meeting notes below:
> >
> > 1) We have to use AMQP 0.9.1 because of it's wide usage.
> > 2)Our main focus is AMQP proxy server.
> > 3)The complete project plan and detailed design should be updated.
> >
> > People participated in hangouts: Von Gosling, Zhanhui Li, Heng du,
> > Kasthuriraajan.
> >
> > I'll update my detailed design of project soon in this mailing list. All
> of
> > my questions have cleared for now. If any questions arise during project
> > design, I'll ask in this mailing list.
> >
> > Thank you.
> >
> > Best Regards,
> > R.Kasthuriraajan.
> >
> > On Tue, May 29, 2018 at 11:51 AM, Von Gosling  > wrote:
> >
> >> kindly ping Kasthuriraajan, are you online ？
> >>
> >> 在 2018年5月29日，14:05，Kasthuriraajan Ratnasingam <
> kasthuriraaja...@gmail.com>
> >> 写道：
> >>
> >> Hi Von,
> >>
> >> Kind reminder on today's meeting. I'm ready in hangouts.
> >>
> >> Thanks,
> >> R.Kasthuriraajan.
> >>
> >> On Mon, May 28, 2018 at 9:06 PM, Kasthuriraajan Ratnasingam <
> >> kasthuriraaja...@gmail.com> wrote:
> >>
> >>> Hi Von,
> >>>
> >>> Thank you for the reply.
> >>>
> >>> Yes we can meet through hangouts, tomorrow (29 ,May 2018) 2:00 pm
> GMT+8.
> >>> I have sent you an invitation to " *vongosl...@apache.org
> >>> > *" for google hangouts.
> >>>
> >>>
>  I think the programme has started as GSoC schedule, Isn't it?
> 
> >>> Yes. But I asked about our meeting start time. Sorry for the
> >>> inconvenience.
> >>>
> >>> Let's meet tomorrow.
> >>>
> >>> Thank you.
> >>>
> >>> Best regards,
> >>> R.Kasthuriraajan.
> >>>
> >>> --
> >>> R.Kasthuriraajan.
> >>> Undergraduate student | Department of Computer Science,
> >>> Faculty of Science | University of Jaffna.
> >>>
> >>> LinkedIn: https://www.linkedin.com/in/ratnasingam-kasthurira <
> https://www.linkedin.com/in/ratnasingam-kasthurira>
> >>> ajan-2a6892121/
> >>>  https://www.linkedin.com/in/ratnasingam-kasthuriraajan-2a6892121/>>
> >>> stackoverflow: https://stackoverflow.com/users/8870269/ <
> https://stackoverflow.com/users/8870269/>
> >>> kasthuriraajan?tab=profile
> >>> GitHub: https://github.com/kasthuriraajan  kasthuriraajan>
> >>> Medium: https://medium.com/@Kasthuriraajan  Kasthuriraajan>
> >>>
> >>>
> >>
> >>
> >> --
> >> R.Kasthuriraajan.
> >> Undergraduate student | Department of Computer Science,
> >> Faculty of Science | University of Jaffna.
> >>
> >> LinkedIn: https://www.linkedin.com/in/ratnasingam- <
> https://www.linkedin.com/in/ratnasingam->
> >> kasthuriraajan-2a6892121/
> >>  https://www.linkedin.com/in/ratnasingam-kasthuriraajan-2a6892121/>>
> >> stackoverflow: https://stackoverflow.com/users/8870269/kasthuriraajan?
> tab= 
> >> profile
> >> GitHub: https://github.com/kasthuriraajan  kasthuriraajan>
> >> Medium: https://medium.com/@Kasthuriraajan  Kasthuriraajan>
> >>
> >>
> >>
> >
> >
> > --
> > R.Kasthuriraajan.
> > Undergraduate student | Department of Computer Science,
> > Faculty of Science | University of Jaffna.
> >
> > LinkedIn: https://www.linkedin.com/in/ratnasingam-kasthuriraajan-
> 2a6892121/  2a6892121/>
> >  https://www.linkedin.com/in/ratnasingam-kasthuriraajan-2a6892121/>>
> > stackoverflow:
> >

Re: The State of RocketMQ Streaming Integration

2018-04-23 Thread Xin Wang 
Thanks very much. Glad to see that more users use and participate in the
bigdata eco-system connectors.

- Xin

2018-04-23 19:59 GMT+08:00 Von Gosling <vongosl...@apache.org>:

> HI Xing,
>
>
> Cool, some guys have looking for me to ask for help in the RocketMQ Data
> Connector, I am glad to introduce your works to them. Let’s put forward it
> together :-)
>
> BTW, I will merge some updates of the wiki which you have provided.
>
> Best Regards,
> Von Gosling
>
> > 在 2018年4月20日，14:47，Xin Wang <data.xinw...@gmail.com> 写道：
> >
> > Hi folks,
> >
> > Now the improvements for RocketMQ-Storm has been merged into master.
> >
> > Here is the latest state of rocketmq streaming integration:
> >ModuleStatus
> > * RocketMQ-StormAvailable
> > * RocketMQ-SparkAvailable, improvements patch to be merged.
> > * RocketMQ-Flink Available
> > * RocketMQ-Serializer(including JSON, Apache Avro)Available, to be
> merged.
> >
> > Some new modules on the road:
> > * RocketMQ-SQL  https://issues.apache.org/jira/browse/ROCKETMQ-357 <
> https://issues.apache.org/jira/browse/ROCKETMQ-357>
> > * RocketMQ-Beam(Beam IO)
> >
> >
> > Recently, I'm working on the RocketMQ SQL. Hope the initial version can
> be released ASAP. Anybody who is interested in please join me.
> >
> >
> > Thanks,
> > Xin Wang
> >
>
>


-- 
Thanks,
Xin

Re: The State of RocketMQ Streaming Integration

2018-04-20 Thread Xin Wang 
Hi folks,

Now the improvements for RocketMQ-Storm has been merged into master.

Here is the latest state of rocketmq streaming integration:
   ModuleStatus
* RocketMQ-Storm*Available*
* RocketMQ-Spark*Available, improvements patch to be merged.*
* RocketMQ-Flink *Available*
* RocketMQ-Serializer(including JSON, Apache Avro)*Available, to be
merged.*

Some new modules on the road:
* RocketMQ-SQL  https://issues.apache.org/jira/browse/ROCKETMQ-357
* RocketMQ-Beam(Beam IO)


Recently, I'm working on the RocketMQ *SQL*. Hope the initial version can
be released ASAP. Anybody who is interested in please join me.


Thanks,
Xin Wang

Re: The State of RocketMQ Streaming Integration

2018-03-25 Thread Xin Wang 
Hi folks,

I'm glad to say that the RocketMQ-Flink module has been merged into master.
https://github.com/apache/rocketmq-externals/tree/master/rocketmq-flink

Here is the state of rocketmq streaming integration:
   ModuleStatus
* RocketMQ-Storm*Available*
* RocketMQ-Spark*Available*, *The improvements will be available soon*.
* RocketMQ-Flink *Available*
* RocketMQ-Serializer(including JSON, Apache Avro)*Available*, *Not
merged yet*.

And, some new modules on the road:
* RocketMQ-SQL  https://issues.apache.org/jira/browse/ROCKETMQ-357
* RocketMQ-Beam(Beam IO)


Anybody who is interested in these tasks too, please join me. Let's fight
together.


Thanks,
Xin Wang



2018-01-27 19:35 GMT+08:00 Xin Wang <data.xinw...@gmail.com>:

> Hi devs,
>
> I'd like to update the state of RocketMQ Streaming Integration:
> Now the task for RocketMQ-Flink  integration is completed and  patch is
> available here: https://github.com/apache/rocketmq-externals/pull/45
> Following is the brief changelog:
>
>- RocketMQSource - The RocketMQSource is based on RocketMQ pull
>consumer mode, and provides exactly once reliability guarantees when
>checkpoints are enabled.
>Otherwise, the source doesn't provide any reliability guarantees.
>- RocketMQSink - The RocketMQSink provides at-least-once reliability
>guarantees when checkpoints are enabled and withBatchFlushOnCheckpoint
>(true) is set.
>Otherwise, the sink reliability guarantees depends on rocketmq
>producer's retry policy, for this case, the messages sending way is sync by
>default,
>but you can change it by invoking withAsync(true).
>- KeyValueDeserializationSchema - The main API for deserializing topic
>and tags is the org.apache.rocketmq.flink.common.serialization.
>KeyValueDeserializationSchema interface.
>rocketmq-flink includes general purpose KeyValueDeserializationSchema 
> implementations
>called SimpleKeyValueDeserializationSchema.
>- KeyValueSerializationSchema - The main API for serializing topic and
>tags is the org.apache.rocketmq.flink.common.serialization.
>KeyValueSerializationSchema interface.
>rocketmq-flink includes general purpose KeyValueSerializationSchema 
> implementations
>called SimpleKeyValueSerializationSchema.
>- TopicSelector - The main API for selecting topic and tags is the
>org.apache.rocketmq.flink.common.selector.TopicSelector interface.
>rocketmq-flink includes general purpose TopicSelector implementations
>called DefaultTopicSelector and SimpleTopicSelector.
>- RocketMQFlinkExample - which receive messages from RocketMQ brokers
>and send messages to broker after processing.
>
> Any comments are welcome. And anybody who is also interested in these
> tasks, please join me. Let's fight together.
>
> Thanks,
> Xin Wang
>
>
> 2018-01-19 21:47 GMT+08:00 yukon <yu...@apache.org>:
>
>> Cool, thanks for your outstanding contribution, to help RocketMQ community
>> integrate with other streaming platforms.
>>
>> On Fri, Jan 19, 2018 at 7:52 PM, Xin Wang <data.xinw...@gmail.com> wrote:
>>
>> > Hi devs,
>> >
>> > I have finished the improvements for integrating RocketMQ with Apache
>> > Storm.
>> > Main changes are as following:
>> >
>> >- Upgraded RocketMQ version to 4.2.0 which brings improvements and
>> new
>> >features like batch sending
>> >- Imporved retry policy for RocketMQ consumer push mode to avoid data
>> >loss in some scenes
>> >- Batch sending supported for bolt and trident state
>> >- Allow running several consumer instances in one process, that is to
>> >say, different topics in one worker is possible
>> >
>> > PR: https://github.com/apache/storm/pull/2518
>> >
>> > And I submit the `RocketMQ-Serializer` patch several days ago. This
>> module
>> > includes several serialization formats, especially Apache Avro which I
>> > stated before[1].
>> >
>> >- Raw String
>> >- JSON
>> >- Avro Generic
>> >- Avro Specified
>> >
>> > PR: https://github.com/apache/rocketmq-externals/pull/42
>> >
>> > Any comments for these PRs are welcome. BTW here is the state of
>> rocketmq
>> > streaming integration:
>> >ModuleStatus
>> > * RocketMQ-StormPatch Available
>> > * RocketMQ-SparkTo Refactor
>> > * RocketMQ-Flink Patch Available Soon
>> > * RocketMQ-Serializer Patch Available
>> >
>> > Anybody who is also interested in these tasks, please join me. Let's
>> fight
>> > together.
>> >
>> >
>> > [1] https://issues.apache.org/jira/browse/ROCKETMQ-157
>> >
>> >
>> > Thanks,
>> >
>> > Xin Wang (vesense)
>> >
>>
>
>
>
> --
> Thanks,
> Xin
>



-- 
Thanks,
Xin

Notes on contributor experience

2018-03-21 Thread Xin Wang 
Hi folks,

There are some good notes on contributor experience from Apache Beam
Community.
Maybe we can learn from it.

https://docs.google.com/document/d/1WaK39qrrG_P50FOMHifJhrdHZYmjOOf8MgoObwCZ
I50/edit


-- 
Thanks,
Xin

Re: rocketmq问题咨询

2018-03-21 Thread Xin Wang 
您好，

由于这是一个开放性问题，故抄送dev mailing list。

RocketMQ社区目前有开源rocketmq-console可供参考：
https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

谢谢。


在 2017年5月17日 下午5:35，肖林 写道：

> 您好！
>   请问rocketmq 有运维页面吗？  是否开源。
>   麻烦指点一下，谢谢
>
>
>
>


-- 
Thanks,
Xin

Re: 请教rocketmq-spark问题

2018-03-21 Thread Xin Wang 
你好，
很抱歉错过了这封邮件。由于这是个已知问题为了减少对用户的影响，故抄送到dev mailing list。

这是RocketMQ-Spark去年已经修复的一个BUG（详情：
https://github.com/apache/rocketmq-externals/pull/36）
可以使用最新版本解决此问题。

BTW，RocketMQ-Spark近期将会进行一次优化改进，为RocketMQ用户提供一个更稳定、可靠的大数据集成组件。

谢谢。

在 2017年10月14日 下午7:53，Yingjun Li 李颖俊 写道：

> 你好：
> 最近我在使用apache/rocketmq-externals 这个项目里面有关spark-streaming
> 的插件，然后通过在github上面了解到consumer push mode是你实现合并上去的。方便打扰一下向你请教点问题吗？
> 我运行的环境如附件。
>
>
> JavaInputDStream stream = RocketMqUtils.
> createJavaReliableMQPushStream(
> jscc,pushConsumerProperties,StorageLevel.MEMORY_AND_DISK_
> SER());
>
> 我采用的是reliable的push mode，数据可以从rocketMQ出来存进去队列BlockingQueue
> queue;
> 但是到了这一步
>
> try {
> // According to the official docs
> // 'To implement a reliable receiver, you have to use
> store(multiple-records) to store data'
> ReliableRocketMQReceiver.this.store(messageSet);
> ack(messageSet.getId());
>  } catch (Exception e) {
>  fail(messageSet.getId());
>  }
>  MessageSender的进程就一直卡住了，过一段时间就出现OOM错误，如下：
>
>  java.lang.OutOfMemoryError: Java heap space
> at scala.reflect.ManifestFactory$$anon$2.newArray(Manifest.
> scala:177)
> at scala.reflect.ManifestFactory$$anon$2.newArray(Manifest.
> scala:176)
> at org.apache.spark.util.collection.PrimitiveVector.
> copyArrayWithLength(PrimitiveVector.scala:87)
> at org.apache.spark.util.collection.PrimitiveVector.
> resize(PrimitiveVector.scala:74)
> at org.apache.spark.util.collection.SizeTrackingVector.
> resize(SizeTrackingVector.scala:35)
> at org.apache.spark.util.collection.PrimitiveVector.$
> plus$eq(PrimitiveVector.scala:41)
> at org.apache.spark.util.collection.SizeTrackingVector.
> $plus$eq(SizeTrackingVector.scala:30)
> at org.apache.spark.storage.memory.MemoryStore.
> putIteratorAsValues(MemoryStore.scala:216)
> at org.apache.spark.storage.BlockManager$$anonfun$
> doPutIterator$1.apply(BlockManager.scala:1038)
> at org.apache.spark.storage.BlockManager$$anonfun$
> doPutIterator$1.apply(BlockManager.scala:1029)
> at org.apache.spark.storage.BlockManager.doPut(
> BlockManager.scala:969)
> at org.apache.spark.storage.BlockManager.doPutIterator(
> BlockManager.scala:1029)
> at org.apache.spark.storage.BlockManager.putIterator(
> BlockManager.scala:792)
> at org.apache.spark.streaming.receiver.
> BlockManagerBasedBlockHandler.storeBlock(ReceivedBlockHandler.scala:84)
> at org.apache.spark.streaming.receiver.ReceiverSupervisorImpl.
> pushAndReportBlock(ReceiverSupervisorImpl.scala:158)
> at org.apache.spark.streaming.receiver.ReceiverSupervisorImpl.
> pushIterator(ReceiverSupervisorImpl.scala:138)
> at org.apache.spark.streaming.receiver.Receiver.store(
> Receiver.scala:152)
> at org.apache.rocketmq.spark.streaming.ReliableRocketMQReceiver$
> MessageSender.run(ReliableRocketMQReceiver.java:119)
>
>通过dump发现List实例过多的问题，但是我本身才往rocketMQ插入500条记录。
> num #instances #bytes  class name
> --
>1:  5005  537537816  [Ljava.lang.Object;
>2:  1664  135648072  [B
>3: 308462588360  [C
>
> 后面我就暂时无解了，只是猜测会不会跟MessageSet 里面的private List data有关。
> 看到邮件如果有时间方便的话非常希望能得到你的帮助，谢谢!
>
>   李颖俊
>
>
> 2017.10.14
>
>
>




-- 
Thanks,
Xin

Re: [VOTE] Accept RocketMQ CPP SDK Code Donation

2018-02-05 Thread Xin Wang 
+1

2018-02-05 16:04 GMT+08:00 yukon :

> Hi all,
>
> Following an earlier discussion thread, I’d like to start of VOTE on
> whether to accept the RocketMQ CPP SDK donation from Qiwei Wang.
>
> RocketMQ CPP SDK is a stable, widely used C++ client SDK of Apache
> RocketMQ, for Linux and Windows platform. It supports full features of
> RocketMQ Java client and has played an important role in many distributed
> applications of Alibaba Group.
>
> The process is tracked under ROCKETMQ-352 and the source code is available
> here:
>
> https://issues.apache.org/jira/secure/attachment/12905462/rocketmq-cpp.zip
> sha1: c3553dbe3c1524fe4afb3a619e2c7acfdf9eefed
>
> The IP Clearance document:
> http://incubator.apache.org/ip-clearance/rocketmq-cpp-sdk.html
>
> Please vote to approve this contribution.  Lazy consensus applies: if no -1
> votes are cast
>
> within the next 72 hours, the vote passes.
>
> [ ] +1 Accept FileVault into Apache Jackrabbit
> [ ] -1 Reject the contribution because...
>
> Regards,
> yukon
>



-- 
Thanks,
Xin

The State of RocketMQ Streaming Integration

2018-01-19 Thread Xin Wang 
Hi devs,

I have finished the improvements for integrating RocketMQ with Apache Storm.
Main changes are as following:

   - Upgraded RocketMQ version to 4.2.0 which brings improvements and new
   features like batch sending
   - Imporved retry policy for RocketMQ consumer push mode to avoid data
   loss in some scenes
   - Batch sending supported for bolt and trident state
   - Allow running several consumer instances in one process, that is to
   say, different topics in one worker is possible

PR: https://github.com/apache/storm/pull/2518

And I submit the `RocketMQ-Serializer` patch several days ago. This module
includes several serialization formats, especially Apache Avro which I
stated before[1].

   - Raw String
   - JSON
   - Avro Generic
   - Avro Specified

PR: https://github.com/apache/rocketmq-externals/pull/42

Any comments for these PRs are welcome. BTW here is the state of rocketmq
streaming integration:
   ModuleStatus
* RocketMQ-StormPatch Available
* RocketMQ-SparkTo Refactor
* RocketMQ-Flink Patch Available Soon
* RocketMQ-Serializer Patch Available

Anybody who is also interested in these tasks, please join me. Let's fight
together.


[1] https://issues.apache.org/jira/browse/ROCKETMQ-157


Thanks,

Xin Wang (vesense)

Re: 求助，在哪里查看完整的项目文档？

2017-11-27 Thread Xin Wang 
hi,

基础入门请参考官网：https://rocketmq.apache.org/docs/quick-start/
example源码：https://github.com/apache/rocketmq/tree/master/example
如你所见，文档确实需要进一步完善，有兴趣的同学可以参与贡献。
https://rocketmq.apache.org/docs/how-to-contribute/
另外，咨询或建议类问题建议发送邮件至user mailing list。

Thanks,
Xin

在 2017年11月28日 上午11:34，852428...@qq.com <852428...@qq.com>写道：

> 我找遍了官网，只有几个demo和简单的介绍，找不到完整的教程文档。在百度上也找不到完整的教程，有的教程都非常零碎。
> 请问在什么地方有完成的文档可以看，或者官方根本就没有文档。谢谢。
>
>
>
> 852428...@qq.com
>



-- 
Thanks,
Xin

Re: [STARTUP]Apache RocketMQ Shenzhen Meetup

2017-11-27 Thread Xin Wang 
Hi Von,
Is the time correct? 2018??  - Xin

2017-11-27 16:15 GMT+08:00 Von Gosling :

> Dear Apache RocketMQ Community,
>
> I am excited to call for the second meetup in Shenzhen, China at Dec. 16
> pm., 2018. Please have a look at your schedule, and consider submitting a
> talk to the community.  The overarching message about this meetup is
> “Apache RocketMQ: Messaging and Streaming’s Technology Today“, and we wish
> to highlight the fact that Apache RocketMQ is where tomorrow is invented -
> you are the ones inventing it.
>
>
> For further updated about this Meetup, follow us on Twitter,
> @ApacheRocketMQ, or contact me - vongosl...@apache.org - with any
> questions or concerns.
>
>
>
> Thanks!
> Von Gosling




-- 
Thanks,
Xin