Weight distribution for kafka consumer apps

[Vignesh-Au]

Hello, I am new to argo rollout. I am trying to use canary deployment for a kafka consumer app and was able to test out basic functionalities and it looks good.

I would like to know how the weight distribution happens for kafka consumer apps. For example, when using nginx service, we can define weights at each step to control how much traffic should be used for a canary release. But how can we control the weights for kafka consumer app?

I could not find an example for such use cases in the docs. Can someone please put me in the right direction?

Thanks in advance!

[Vignesh-Au]

Found an example. This can be closed.

canary:
maxSurge: 0
maxUnavailable: 1
stableMetadata:
labels:
role: "stable"
canary: "false"
canaryMetadata:
labels:
role: "canary"
canary: "true"
steps:

• setWeight: 1
• pause: { }