使用 EventHubTrigger 配置自定义 ConsumerGroup

Question

我想将 EventHubTrigger 与自定义 ConsumerGroup 一起使用。

使用默认 ConsumerGroup 时的代码如下所示：

public static async Task ProcessQueueMessage([EventHubTrigger("%EventHubName%")] TelemetryEvent[] messages, TextWriter log)
        {}

EventHubTriggerAttribute 类有一个可以设置的 ConsumerGroup 属性。但是怎么做呢？

[AttributeUsage(AttributeTargets.Parameter)]
public sealed class EventHubTriggerAttribute : Attribute
{
    //
    // Summary:
    //     Create an instance of this attribute.
    //
    // Parameters:
    //   eventHubName:
    //     Event hub to listen on for messages.
    public EventHubTriggerAttribute(string eventHubName);

    //
    // Summary:
    //     Name of the event hub.
    public string EventHubName { get; }
    //
    // Summary:
    //     Optional Name of the consumer group. If missing, then use the default name, "$Default"
    public string ConsumerGroup { get; set; }
}

Answer 1

据我所知，如果想在EventHubTrigger中设置ConsumerGroup属性，可以在EventHubTrigger方法中设置为参数。

更多细节，您可以参考以下代码：

    public static async Task ProcessQueueMessage([EventHubTrigger("Yourhubname", ConsumerGroup = "groupname")] string[] messages, TextWriter log)
    {
       ...
    }