在分布式消息队列系统中，如Kafka和RocketMQ，消费者可以分配到多个分区或队列以实现高效的消息处理。例如，如果有8个分区或队列，而消费者分布在三台机器上，则每台机器上的消费者将分别消费3、3和2个分区或队列。

对于单机多线程消费模式，RocketMQ允许通过设置setConsumeThreadMin和setConsumeThreadMax来控制消费者的线程数量。外部可以通过ThreadPoolExecutor实现这一点。相比之下，Kafka的消费者在同一进程中是线程不安全的，因此需要为每个线程单独创建一个消费者实例。无论是Kafka还是RocketMQ，它们能够同时消费的消息数量都受到分区或队列数量的限制。

然而，在单机多线程消费模式下，必须谨慎管理线程数量，以防设置过多线程导致CPU过载。这有助于减轻系统峰值负载，即所谓的“削峰填谷”。

为了优化消费性能，可以根据消费服务所用机器的配置、消费速度以及对延迟的容忍度来反向推算应配置的分区数量。如果机器配置较高且消费速度快，可以考虑增加分区数量和消费者实例数量。相反，如果机器配置较低且消费速度较慢，也可以增加分区数量，但应同时扩展服务规模，增加更多的机器来应对高延迟问题。