Skip to content
This repository was archived by the owner on Dec 16, 2021. It is now read-only.
This repository was archived by the owner on Dec 16, 2021. It is now read-only.

updating kafkatrigger resource does not delete old trigger #20

Description

@yvz5

When I create a kafka trigger from a yaml file like so:

apiVersion: kubeless.io/v1beta1
kind: KafkaTrigger
metadata:  
  labels:
    created-by: kubeless
  name: python-demo-trigger
  namespace: kubeless
spec:
  functionSelector:
    matchLabels:
      created-by: kubeless
      function: python-demo
  topic: python-demo # subscribes to this kafka topic

and change the topic, the function is run even if the old topic is triggered.

I have a chain of events and I would like to add / remove functions inside the chain. If the old relation / connection between topic and function remains the same, now my function is run twice, which is not wanted.

Do you delete the old topic - function relation when the trigger is updated ?

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Fields

    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions