goka NumPartitions

在 Goka 中，`NumPartitions` 是用于指定输入或输出 Topic 所包含的 partition 数量的属性。Partition 是 Kafka 中用于实现分布式消息处理的重要概念，它将一个 Topic 中的消息划分为多个部分，并将这些部分分配给不同的 Consumer 进行处理。在 Goka 中，每个 Processor 都会针对其输入 Topic 的每个 partition 启动一个 Consumer，并独立地处理每个 partition 中的消息。

通过指定 `NumPartitions` 属性，可以控制输入或输出 Topic 中 partition 的数量。默认情况下，如果没有为 Topic 显式地指定 partition 数量，则会使用 Goka 框架的默认值（通常为 1）。在实际应用中，通常需要根据输入或输出流的负载情况来设置 partition 的数量，以便在多个 Consumer 之间实现负载均衡和并行处理。需要注意的是，一旦 Topic 被创建，就不能再更改其 partition 数量。如果需要更改 partition 数量，需要先删除该 Topic，并重新创建一个新的 Topic。