-
Task
-
Resolution: Done
-
Major
-
None
-
None
-
integration-doc-2021-12-27, integration-doc-2022-01-17
As suggested by Lucie (QE) update
section 2.2.2.4
Creating a secret by using the SASL/Plain authentication method
(which refers to PlainLoginModule) there could be added example of kameletbinding with kafka-source/sink connecting to RHOAS managed kafka instance.
(the kamelets kafka-source/sink use PlainLoginModule and seems to me as useful and intended usecase. It requires the "user" and "password" parameters, unlike in case of unauthenticated kafka instance on AMQ Streams, which need just any nonempty string).
In case of SASL/Plain authentication method (ie. with the PlainLoginModule), the kafka-source/sink kamelet can also be used to connect to RHOAS kafka instance:
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: kafka-to-log
spec:
source:
ref:
kind: Kamelet
apiVersion: camel.apache.org/v1alpha1
name: kafka-source
properties:
bootstrapServers: "<YOUR-KAFKA-BOOTSTRAP-URL-HERE>" # e.g. lfabriko-c-drndmbv-s-r-yy-xxx.bf2.kafka.rhcloud.com:443
password: "<YOUR-SERVICE-ACCOUNT-SECRET-HERE>"
topic: "TOPIC-NAME"
user: "<YOUR-SERVICE-ACCOUNT-ID-HERE>"
sink:
uri: "log:info"