如何将传入消息映射到 Azure Eventhub 中的使用者组

How to map incoming messages to a consumer group in Azure Eventhub

我正在尝试使用 Azure EventHub 来处理消息,只要我有一个发送者和一个消费者,它就可以正常工作。

我只是让我的消费者收听特定的消费者组,一切都很好

现在的问题是,当我发送我希望由不同的消费者组处理的不同类型的消息时,我不知道如何做到这一点

我正在这样创建我的发件人

private static EventHubProducerClient eventHubClient = new EventHubProducerClient(eventHubConnectionString, eventHubName);

但我找不到告诉它应该发送给哪个消费者组的方法,它简单地发送给集线器本身并且该集线器有多个资源组

我如何决定接收此消息的消费者组?

我在谷歌上搜索了几个小时都没有找到"map"将来自特定发件人的消息输入到特定输出消费者组的方法

您不能指定将哪条消息发送到指定的消费者组。消息发送到分区,分区都包含在每个消费者组中,你可以查看doc中的图表。截图如下:

Now for you question: when I send different types of messages that I want processed by different Consumer Group I dont see how that can be done.

作为解决方法,当您发送消息时,您可以 specify a property 每条消息。当从消费者组读取这些消息时,也可以通过属性来判断是处理还是放弃。

希望对您有所帮助。