请教一个关于多进程设计的问题~

场景：具有优先级设置的消息系统，目前准备基于 kafka 实现。

希望实现：
1. 多进程的统一管理调度
2. 保证优先级高的消息，优先处理
3. 保证优先级低的消息，不会因为优先级高的消息处理失败而堵塞

======================================

一个不太优的方案：
1. 将不同的消息类型定义为主题，具有优先级(1-10)属性。
2. 配置最大处理进程数

启动进程(主进程)获取到所有定义的主题，按照优先级生成不同的监听进程。
生成一个进程监控 1 个优先级为 1 的主题
生成一个进程监控 2 个优先级为 2 的主题
。。。
生成一个进程监控 10 个优先级为 10 的主题

当优先级低于 3 的监控进程，没有消息处理的时间超过一定阈值(按照优先级设定)，就通知主进程过一定时间后重启。


缺点：
当优先级高的消息处理时，进程数没有到达最大处理进程数的时候，也不会开启进程处理
当主题变多的时候，需要进程数也变多，很容易造成瓶颈。

=========================================

作为 phper 接触到进程管理的概念也比较少，希望有同学能指点一下~~