Using a Kafka activity is causing duplicated WorkFlowTrigger instance

[dao74]

I have added a Kafka activity into a flow and saw that the flow is running twice.

Checking of the Triggers table: the records related to the Kafka activity were duplicated.

After debug I found out the duplication was caused in the Elsa.Services.Triggers.TriggersForActivityBlueprintAndWorkflowProvider. **GetTriggersForActivityBlueprintAsync** method.

supportedBookmarkProviders =
Elsa.Activities.Kafka.Bookmarks.OverrideKafkaBookmarkProvider,
Elsa.Activities.Kafka.Bookmarks.QueueMessageReceivedBookmarkProvider

GetTriggersForBookmarkProvider is returning 2 items WorkflowTrigger with identical values (ActivityType=KafkaMessageReceived)

Please check and advise.

[sfmskywalker]

@Snotax Maybe you experienced this as well?

[Snotax]

@sfmskywalker I will check on monday, but from memory I don't think that my workflows got triggered multiple times.

[sfmskywalker]

Perfect, thank you!

[sfmskywalker]

@dao74 This should be fixed now with the preview build (https://github.com/elsa-workflows/elsa-core/actions/runs/4530401599) with to the PR from @Snotax

[dao74]

Seems working, thank you.