【Azure 事件中心】azure-spring-cloud-stream-binder-eventhubs客户端组件问题, 实践消息非顺序可达

问题描述

查阅了Azure的官方文档( 将事件发送到特定分区: )，在工程里引用组件“azure-spring-cloud-stream-binder-eventhubs”来连接EventHub发送和消费消息事件。在发送端一个For循环中发送带顺序号的消息，编号从0开始，并且在消息的header中指定了 "Partition Key"，相同PartitionKey的消息会被发送到相同的Partition，来保证这些消息的顺序。

但是在消费端的工程中消费这些消息时，看到打印到日志中的结果并不是从0递增的。所以想知道是发送端在发送时就已经乱序发送了？还是消息到达EventHub后乱序保存了？还是消费端的消费方式的问题，导致打印出的结果是乱序的？

 

下面是发送端的代码：

public void testPushMessages(int mcount, String partitionKey) { String message = "Message "; for (int i=0; i <mcount; i++) { source.output().send(MessageBuilder.withPayload(partitionKey + mcount + i).setHeaderIfAbsent(AzureHeaders.PARTITION_KEY,partitionKey).build()); } }