Benutzerdefinierte ConsumerGroup mit EventHubTrigger konfigurieren

Question

Ich möchte den EventHubTrigger mit einer benutzerdefinierten ConsumerGroup verwenden.

Der Code sieht wie folgt aus, wenn die Standard-ConsumerGroup mit:

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

Die EventHubTriggerAttribute Klasse eine ConsumerGroup Eigenschaft hat, die eingestellt werden können. Aber wie?

[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

Soweit ich weiß, wenn Sie ConsumerGroup Eigenschaft in EventHubTrigger festlegen möchten, können Sie es als Parameter in der EventHubTrigger Verfahren einstellen könnte.

Weitere Details können Sie verweisen Codes folgen:

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