以编程方式查询事件中心使用者组(并在需要时创建)

Programmatically query Event Hub Consumer Group (and create if required)

有谁知道如何使用 .NET SDK 在 Azure 事件中心查询和创建使用者组。我已经用谷歌搜索了负载,只能找到通过 REST API 的方法(我可以做到,但如果我可以通过 SDK 做到这一点会更好)。 提前致谢

NamespaceManager.CreateConsumerGroupIfNotExistsAsync(...)

ConsumerGroupDescription realtimeCG = nsMgr.CreateConsumerGroupIfNotExists("PartitionedStream_AKA_EventHub_Name");

Does anyone know how to query and create consumer groups in Azure Event Hubs using the .NET SDK.

你可以尝试安装this NuGet package,正如Sreeram所说,我们可以使用NamespaceManager class来创建消费者组。

var manager = NamespaceManager.CreateFromConnectionString("{your connection string}");
manager.CreateConsumerGroupIfNotExists("{eventHubPath}", "{consumergroup Name}");

执行代码后,您会发现消费者组已创建。

要获取消费者组,您可以尝试调用EventHubClient.GetConsumerGroup method

var factory = MessagingFactory.CreateFromConnectionString("{your connection string}");
var client = factory.CreateEventHubClient("{eventHubPath}"); 
EventHubConsumerGroup group = client.GetConsumerGroup("{consumergroup Name}");