Configure Journey Engine with Kafka SASL

  1. Update Journey Engine log4j2.xml file from <JOURNEY_HOME>/Engine/conf/ directory. Uncomment the following lines in log4j2.xml.
     <!-- Kafka SASL configuration -->
    <Property name="security.protocol">${sys:security.protocol}</Property> 
    <Property name="sasl.mechanism">${sys:sasl.mechanism}</Property> 
  2. Update journey_engine_master.config from <JOURNEY_HOME>/Engine/ directory. Update the following property values.
    kafka.security.enabled=Y 
    kafka.security.protocols.enabled=SASL_PLAINTEXT 
    security.protocol=SASL_PLAINTEXT 
    sasl.mechanism=PLAIN 
    java.security.auth.login.config=./kafka_client_jaas.conf