[ 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, [k...@apache.org|mailto:k...@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] [[architecture doc|https://mp.weixin.qq.com/s?__biz=Mzg2NDcxMzgzMA==&mid=2247486423&idx=1&sn=b9b1ac3a9492f951f7ddf8ed50a53097&chksm=ce6466def913efc8fc39fc5e26d59b53996cebf0c76fb7a162892cb1803a69501e070c30b083&token=1627591522&lang=zh_CN#rd]|https://mp.weixin.qq.com/s?__biz=Mzg2NDcxMzgzMA==&mid=2247486386&idx=1&sn=198722f8ba0c65d8a06bcc6c23f42f86&chksm=ce6466bbf913efad859a4a643475d2f2eb2cfe5e351c4e332f40797aab78adebc202af8ff386&scene=21#wechat_redirect] 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, [k...@apache.org|mailto:k...@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] > [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, > [k...@apache.org|mailto:k...@apache.org] > h4. -- This message was sent by Atlassian Jira (v8.20.10#820010) --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@community.apache.org For additional commands, e-mail: dev-h...@community.apache.org