Some questions after reading the design ideas

1.What is the life cycle of each flow in a kafka scenario? If function is abnormal, should the data be discarded? If it should not be discarded, how should it be disposed of?

2.A lot of flow parallelism, how to solve the performance problem? I haven't figured out the right way yet.

No concrete files or tests are referenced in the issue text. Start by reading any design/architecture docs in the repository and any Kafka-related sections in README or examples to see whether flow lifecycle and retry/discard semantics are already defined. Then review existing issues/PRs for similar lifecycle decisions. The issue is done only if it is resolved with a clear documented decision (or converted into a concrete, actionable task), not by code changes yet.

由索引模型根据 Issue 内容生成。