生产者批处理服务总线与Kafka

Question

Kafka 提供了一个功能，我们可以指定生产者批量大小。这是一次可以发送到队列的消息的大小。优点是我们可以减少队列的网络调用次数。我们的服务总线中有类似的东西吗？服务总线唯一执行的批处理操作是在将消息传递到队列时进行。但这并不会减少 I/O 调用的数量。

这里的目标是对生产者发送到服务总线队列的消息进行批量处理，以减少网络调用的次数。

Answer 1

使用 .NET SDK，您可以创建

ServiceBusMessageBatch

。创建批次时，可以传递

CreateMessageBatchOptions

来指定最大批次大小。例如

var options = new CreateMessageBatchOptions { MaxSizeInBytes = 1_024 };
using var messageBatch = await sender.CreateMessageBatchAsync();

将构建最多 1,024 字节的批次。如果未指定，默认情况下，批量将是所使用的命名空间层的最大消息大小，标准为 256KB，高级为 100 MB。