本文是**预发布**文章，废话相当多。并且某些教程未经笔者实测，可能实际效果**欠佳**甚至**完全错误**，在此深表歉意。同时欢迎各位批评指正。 本教程未经打磨，写得**很烂**，不适合初学者观看，很多地方并未完善。 除非另有说明，否则本文章内容依据**CC ...

（2）subExecutor 表示流数据处理线程，可以通过配置文件的 subExecutors 指定节点的最大可用流数据处理线程数。通过设置 subscribeTable 函数中的 hash 参数，指定消费 topic 的流数据处理线程。比如 subExecutor 设置为 n，则 hash 可以从 0 至 n-1 进行指定，对应流数据处理线程 1 至 n。