Sensor with Kafka EventBus does not trigger if depend on 2 events

[ammarar]

Describe the bug A sensor that uses Kafka as the Event bus would not trigger an Argo Workflow if it depends on 2 events.

To Reproduce Steps to reproduce the behavior:

1. Create a Kafka cluster

2. Create a Kafka EventBus, HTTP EventSource, and a Sensor by running kubectl apply -f on the attached file events-bug.zip.

3. Trigger metaflow-event with metaflow.FlowB2.end

{
    "name": "metaflow.FlowB2.end",
    "payload": {
      "name": "metaflow.FlowB2.end",
      "auto-generated-by-metaflow": "True"
    }
}

4. Trigger metaflow-event with metaflow.FlowC2.end

{
    "name": "metaflow.FlowC2.end",
    "payload": {
      "name": "metaflow.FlowC2.end",
      "auto-generated-by-metaflow": "True"
    }
}

Expected behavior The Argo Workflow should submit.

Screenshots If applicable, add screenshots to help explain your problem.

Environment (please complete the following information):

• Kubernetes: v1.27.9
• Argo: v3.5.1
• Argo Events: v1.9.0

Additional context This works correctly on JetStream without any issue.

---

Message from the maintainers:

If you wish to see this enhancement implemented please add a 👍 reaction to this issue! We often sort issues this way to know what to prioritize.

[github-actions[bot]]

This issue has been automatically marked as stale because it has not had any activity in the last 60 days. It will be closed if no further activity occurs. Thank you for your contributions.