Is Tombstone Filter Action
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Preview"
Filter based on the presence of body or not
Usage
This section summarizes how the is-tombstone-filter-action
can be used in various contexts.
Knative Action
The is-tombstone-filter-action
Kamelet can be used as intermediate step in a Knative binding.
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: is-tombstone-filter-action-binding
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: timer-source
properties:
message: "Hello"
steps:
- ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: is-tombstone-filter-action
sink:
ref:
kind: Channel
apiVersion: messaging.knative.dev/v1
name: mychannel
Make sure you have Camel K installed into the Kubernetes cluster you’re connected to.
Save the is-tombstone-filter-action-binding.yaml
file into your hard drive, then configure it according to your needs.
You can run the action using the following command:
kubectl apply -f is-tombstone-filter-action-binding.yaml
Binding to Knative using the Kamel CLI:
The procedure described above can be simplified into a single execution of the kamel bind
command:
kamel bind timer-source?message=Hello --step is-tombstone-filter-action channel:mychannel
This will create the KameletBinding under the hood and apply it to the current namespace in the cluster.
Kafka Action
The is-tombstone-filter-action
Kamelet can be used as intermediate step in a Kafka binding.
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: is-tombstone-filter-action-binding
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: timer-source
properties:
message: "Hello"
steps:
- ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: is-tombstone-filter-action
sink:
ref:
kind: KafkaTopic
apiVersion: kafka.strimzi.io/v1beta1
name: my-topic
Ensure that you’ve installed Strimzi and created a topic named my-topic
in the current namespace.
Make also sure you have Camel K installed into the Kubernetes cluster you’re connected to.
Save the is-tombstone-filter-action-binding.yaml
file into your hard drive, then configure it according to your needs.
You can run the action using the following command:
kubectl apply -f is-tombstone-filter-action-binding.yaml
Binding to Kafka using the Kamel CLI:
The procedure described above can be simplified into a single execution of the kamel bind
command:
kamel bind timer-source?message=Hello --step is-tombstone-filter-action kafka.strimzi.io/v1beta1:KafkaTopic:my-topic
This will create the KameletBinding under the hood and apply it to the current namespace in the cluster.