Kubeless PubSub Triggers

Kubeless functions can be invoked by sending input messages to topics in messaging systems. This method is known as a PubSub mechanism. Currently, Kubeless supports two messaging systems, namely, Kafka and NATS.

In order to create PubSub triggers in Kubeless, we need to have a running Kafka cluster or NATS cluster. Once the Kafka or NATS cluster is ready, we can use kubeless trigger kafka create to create a Kafka trigger or kubeless trigger nats create to create a NATS trigger and associate our PubSub function with the new trigger:

$ kubeless trigger <trigger-type> create <trigger-name> \
                             --function-selector <label-query> \
                        ...