Azure / Azure/azure-functions-java-worker
ServiceBus support with partition and duplicate detection
- Lingua principale
- Java
- Stelle
- 103
- Fork
- 74
- Merge medio
- 4g 8h
- PR unite (30g)
- 2
Descrizione
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
Guida per i contributori
Apri la guida per i contributori
Direzione di ricerca
Iniziare dal binding @ServiceBusTopicOutput nella funzione QueueTrigger riprodotta e dall'eccezione Service Bus segnalata. Tracciare il modo in cui il worker Java crea il Message in uscita per le entità partizionate con il rilevamento dei duplicati abilitato. Il lavoro è completo quando la riproduzione fornita non fallisce più, mantenendo il comportamento previsto di partizionamento e rilevamento dei duplicati.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- azure, java
- Ambito
- backend, distributed-systems
- Tipo di issue
- Bug
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Stato di attività
- Ferma
- Chiarezza
- Da chiarire
- Idoneità per principianti
- 25/100