Using a Configuration Parameter

Alternatively to the configuration file, use the configuration parameter as follows:

1. Set the JAAS-configuration by using one of the Kafka properties
   Example

   props.setProperty(SaslConfigs.SASL_JAAS_CONFIG, "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"myuser\" password=\"password\";");

   CODE

2. Substitute <username> and <password> by the credentials provided by Mapp.

   

   The user and password are sensitive data, and therefore, we recommend not to keep them on the code but setting them up dynamically using environment variables.