You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@community.apache.org by "Ni Ze (Jira)" <ji...@apache.org> on 2023/03/20 02:07:00 UTC
[jira] [Updated] (COMDEV-523) GSoC: Observability Improvement for RocketMQ Streams
[ https://issues.apache.org/jira/browse/COMDEV-523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ni Ze updated COMDEV-523:
-------------------------
Description:
h2. *RocketMQ Streams*
RocketMQ Streams is a lightweight stream processing framework, application gains the stream processing ability by depending on RocketMQ Streams as an SDK.
h2. Background
Repo of RocketMQ Streams: [https://github.com/apache/rocketmq-streams]
The architecture document of RocketMQ Streams: [RocketMQ Streams examples |https://mp.weixin.qq.com/s?__biz=Mzg2NDcxMzgzMA==&mid=2247486386&idx=1&sn=198722f8ba0c65d8a06bcc6c23f42f86&chksm=ce6466bbf913efad859a4a643475d2f2eb2cfe5e351c4e332f40797aab78adebc202af8ff386&scene=21#wechat_redirect]
[ Topology Construction and Data Processing Process|https://mp.weixin.qq.com/s?__biz=Mzg2NDcxMzgzMA==&mid=2247486423&idx=1&sn=b9b1ac3a9492f951f7ddf8ed50a53097&chksm=ce6466def913efc8fc39fc5e26d59b53996cebf0c76fb7a162892cb1803a69501e070c30b083&token=1627591522&lang=zh_CN#rd]
h2. *Task*
The observability needs to be enhanced in the following aspects:
* The metric of client/processor/thread/state/rocksdb;
* The topology of streaming process;
* Mutli-output of metrics;
This task need you to study the implementation details of RocketMQ Streams streams, and find out the key indicators in the stream processing process. Design and implement a complete set of observability solutions, and finally use it to complete runtime problem diagnosis;
h2. Mentor
nize, Committer of of Apache RocketMQ, [karp@apache.org|mailto:karp@apache.org]
h4.
was:
h2. *RocketMQ Streams*
RocketMQ Streams is a lightweight stream processing framework, application gains the stream processing ability by depending on RocketMQ Streams as an SDK.
h2. Background
Repo of RocketMQ Streams: [https://github.com/apache/rocketmq-streams]
The architecture document of RocketMQ Streams: [RocketMQ Streams examples |https://mp.weixin.qq.com/s?__biz=Mzg2NDcxMzgzMA==&mid=2247486386&idx=1&sn=198722f8ba0c65d8a06bcc6c23f42f86&chksm=ce6466bbf913efad859a4a643475d2f2eb2cfe5e351c4e332f40797aab78adebc202af8ff386&scene=21#wechat_redirect]
[ Topology Construction and Data Processing Process|https://mp.weixin.qq.com/s?__biz=Mzg2NDcxMzgzMA==&mid=2247486423&idx=1&sn=b9b1ac3a9492f951f7ddf8ed50a53097&chksm=ce6466def913efc8fc39fc5e26d59b53996cebf0c76fb7a162892cb1803a69501e070c30b083&token=1627591522&lang=zh_CN#rd]
h2. *Task*
The observability needs to be enhanced in the following aspects:
* The metric of client/processor/thread/state/rocksdb;
* The topology of streaming process;
* Mutli-output of metrics;
This task need you to study the implementation details of RocketMQ Streams streams, and find out the key indicators in the stream processing process. Design and implement a complete set of observability solutions, and finally use it to complete runtime problem diagnosis;
h2. Mentor
nize, Committer of of Apache RocketMQ, [karp@apache.org|mailto:karp@apache.org]
h4.
> GSoC: Observability Improvement for RocketMQ Streams
> ----------------------------------------------------
>
> Key: COMDEV-523
> URL: https://issues.apache.org/jira/browse/COMDEV-523
> Project: Community Development
> Issue Type: Task
> Reporter: Ni Ze
> Priority: Major
> Labels: RocketMQ, full-time, gsoc2023, mentor
>
> h2. *RocketMQ Streams*
> RocketMQ Streams is a lightweight stream processing framework, application gains the stream processing ability by depending on RocketMQ Streams as an SDK.
> h2. Background
> Repo of RocketMQ Streams: [https://github.com/apache/rocketmq-streams]
> The architecture document of RocketMQ Streams: [RocketMQ Streams examples |https://mp.weixin.qq.com/s?__biz=Mzg2NDcxMzgzMA==&mid=2247486386&idx=1&sn=198722f8ba0c65d8a06bcc6c23f42f86&chksm=ce6466bbf913efad859a4a643475d2f2eb2cfe5e351c4e332f40797aab78adebc202af8ff386&scene=21#wechat_redirect]
> [ Topology Construction and Data Processing Process|https://mp.weixin.qq.com/s?__biz=Mzg2NDcxMzgzMA==&mid=2247486423&idx=1&sn=b9b1ac3a9492f951f7ddf8ed50a53097&chksm=ce6466def913efc8fc39fc5e26d59b53996cebf0c76fb7a162892cb1803a69501e070c30b083&token=1627591522&lang=zh_CN#rd]
> h2. *Task*
> The observability needs to be enhanced in the following aspects:
> * The metric of client/processor/thread/state/rocksdb;
> * The topology of streaming process;
> * Mutli-output of metrics;
> This task need you to study the implementation details of RocketMQ Streams streams, and find out the key indicators in the stream processing process. Design and implement a complete set of observability solutions, and finally use it to complete runtime problem diagnosis;
> h2. Mentor
> nize, Committer of of Apache RocketMQ, [karp@apache.org|mailto:karp@apache.org]
> h4.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@community.apache.org
For additional commands, e-mail: dev-help@community.apache.org