[
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]
[architecture
doc|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, [[email protected]|mailto:[email protected]]
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]
[architecture
doc|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, [[email protected]|mailto:[email protected]]
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]
> [architecture
> doc|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,
> [[email protected]|mailto:[email protected]]
> h4.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
