Question about streaming-02-kafka-to-http sample

[sltfae]

Can this example be used with a Kafka server that requires SASL_SCRAM authentication?

[ndr-brt]

These are samples, so meant to show how it could work, in broad terms.
You can adapt to make it work with that kind of authentication I guess, please note that using PUSH mechanism with a kafka source broughts in a lot of potential issues, the suggested way is to go with the PULL approach, as demonstrated in streaming-03 sample

[sltfae]

What kind of adaptations would I need to do exactly because I tried adding "kafka.security.protocol", "kafka.sasl.mechanism" and "kafka.sasl.jaas.config" to the dataAddress in the asset.json file but this results in an error where it can't construct the kafka consumer when trying to start the transfer process. This error seems to occur when adding "kafka.security.protocol" to the dataAddress and I am not sure how else I would need to add these configurations.