如何自定义工作流消息队列的消费线程数
在修改工作流消息队列的消费线程数前,需要先调整 Kafka 中相关 Topic(WorkFlow
、WorkFlow-Batch
、WorkFlow-Button
、WorkSheet
、WorkSheet-Batch
)的分区数,默认是 3 个分区,消费线程数设置请不要大于分区数。
如何修改 Topic 分区数?
- 进入容器:docker exec -it
docker ps | grep mingdaoyun-community | awk '{print $1}'
bash - 切换到 kafka 目录下:
cd /usr/local/kafka/bin/
- 分别执行以下命令进行分区数调整(如调整为 10 个分区)
./kafka-topics.sh --alter --zookeeper localhost:2181 --partitions 10 --topic WorkFlow ./kafka-topics.sh --alter --zookeeper localhost:2181 --partitions 10 --topic WorkFlow-Batch ./kafka-topics.sh --alter --zookeeper localhost:2181 --partitions 10 --topic WorkFlow-Button ./kafka-topics.sh --alter --zookeeper localhost:2181 --partitions 10 --topic WorkSheet ./kafka-topics.sh --alter --zookeeper localhost:2181 --partitions 10 --topic WorkSheet-Batch
我在文档里看到这个, 这个有什么用呢? 可以提高工作流效率还是?