Ni Ze created COMDEV-523:
----------------------------
Summary: 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
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, [[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]
