Azure / Azure/azure-functions-java-worker
ServiceBus support with partition and duplicate detection
- Vorherrschende Sprache
- Java
- Sterne
- 103
- Forks
- 74
- Ø Merge
- 4 T. 8 Std.
- Gemergte PRs (30 T.)
- 2
Beschreibung
We try to send messages to ServiceBus using functions binding. Bellow Code worked without partitions. But we are facing issues with partition and duplicate detection.
@ServiceBusQueueOutput
@ServiceBusTopicOutput
Sample code to reproduce this issue
```
@FunctionName("QueueTrigger")
public void run(
@ServiceBusQueueTrigger(name = "inMessage", queueName = "%sbInputQueue%", connection = "sbconnection") Message inMessage,
@ServiceBusTopicOutput(name = "topicMessage", topicName = "fx-demo-topic", subscriptionName = "fx-demo-subscription", connection = "sbconnection") OutputBinding topicMessage,
final ExecutionContext context) {
context.getLogger().info("Queue Msg Received " + inMessage.toString());
topicMessage.setValue(inMessage);
context.getLogger().info("Java Service Bus Listing Queue trigger executed.");
}
}
```
Error message :
System.Private.CoreLib: Exception while executing function: Functions.QueueTrigger. Microsoft.Azure.ServiceBus: Message to a partitioned entity with duplicate detection enabled must have either PartitionKey or MessageId
Beitragsleitfaden
Rechercherichtung
Beginnen Sie mit der @ServiceBusTopicOutput-Bindung in der reproduzierten QueueTrigger-Funktion und der gemeldeten Service Bus-Ausnahme. Verfolgen Sie, wie der Java-Worker die ausgehende Message für partitionierte Entitäten mit aktivierter Duplikaterkennung erstellt. Als abgeschlossen gilt die Aufgabe, wenn die bereitgestellte Reproduktion nicht mehr fehlschlägt und dabei das erwartete Partitions- und Duplikaterkennungsverhalten beibehalten wird.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Bewertung
- Tech-Stack
- azure, java
- Bereich
- backend, distributed-systems
- Issue-Typ
- Bug
- Schwierigkeit
- 4/5
- Geschätzter Aufwand
- 3-5 Tage
- Aktivitätsstatus
- Veraltet
- Klarheit
- Muss geklärt werden
- Anfängerfreundlichkeit
- 25/100