Azure / Azure/azure-functions-java-worker
ServiceBus support with partition and duplicate detection
- Langage dominant
- Java
- Étoiles
- 103
- Forks
- 74
- Merge moyen
- 4 j 8 h
- PR mergées (30 j)
- 2
Description
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
Guide de contribution
Ouvrir le guide de contribution
Piste de recherche
Commencez par le binding @ServiceBusTopicOutput dans la fonction QueueTrigger reproduite et par l’exception Service Bus signalée. Suivez la manière dont le worker Java crée le Message sortant pour les entités partitionnées avec la détection des doublons activée. Le travail est terminé lorsque la reproduction fournie n’échoue plus tout en conservant le comportement attendu en matière de partitionnement et de détection des doublons.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
Évaluation
- Stack technique
- azure, java
- Domaine
- backend, distributed-systems
- Type d'issue
- Bug
- Difficulté
- 4/5
- Temps estimé
- 3-5 jours
- Activité
- À l'abandon
- Clarté
- À clarifier
- Accessibilité débutants
- 25/100