Kafka Not Secured Sink
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Preview"
Send data to Kafka topics on an insecure broker.
The Kamelet is able to understand the following headers to be set:
ce-key: as message key
ce-partition-key: as message partition key
Both the headers are optional.
The following table summarizes the configuration options available for the
Comma separated list of Kafka Broker URLs
Comma separated list of Kafka topic names
|Fields marked with (*) are mandatory.|
This section summarizes how the
kafka-not-secured-sink can be used in various contexts.
kafka-not-secured-sink Kamelet can be used as Knative sink by binding it to a Knative object.
apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: kafka-not-secured-sink-binding spec: source: ref: kind: InMemoryChannel apiVersion: messaging.knative.dev/v1 name: mychannel sink: ref: kind: Kamelet apiVersion: camel.apache.org/v1alpha1 name: kafka-not-secured-sink properties: brokers: "The Brokers" topic: "The Topic Names"
Make sure you have Camel K installed into the Kubernetes cluster you’re connected to.
kafka-not-secured-sink-binding.yaml file into your hard drive, then configure it according to your needs.
You can run the sink using the following command:
kubectl apply -f kafka-not-secured-sink-binding.yaml