如何自定义工作流消息队列的消费线程数 这个有什么作用啊?

2 / 68

如何自定义工作流消息队列的消费线程数

在修改工作流消息队列的消费线程数前,需要先调整 Kafka 中相关 Topic(WorkFlowWorkFlow-BatchWorkFlow-ButtonWorkSheetWorkSheet-Batch)的分区数,默认是 3 个分区,消费线程数设置请不要大于分区数。

如何修改 Topic 分区数?

  1. 进入容器:docker exec -it docker ps | grep mingdaoyun-community | awk '{print $1}' bash
  2. 切换到 kafka 目录下:cd /usr/local/kafka/bin/
  3. 分别执行以下命令进行分区数调整(如调整为 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
    

我在文档里看到这个, 这个有什么用呢? 可以提高工作流效率还是?