Setting up Journey to send messages to Kafka topics

In order for the Unica Journey application to send messages to Kafka topics, this setup is required.

About this task

For Kafkalink to work from Unica Link, perform these steps:

Procedure

  1. Update the kafkalink.properties file located in this location: <link_install>/integration-context/install.
  2. Update the following:
    • List of one or more Kafka brokers= IPADDRESS:9092
    • The base URL for the HIP runtime hip-url=https://IPADDRESS:<PORT>/hip-rest/
    • The base URL for the HIP designTime, hip-design-url= https://IPADDRESS:<PORT>/tx-server/rest/
    • App project name project-name=_app_journey
    • The name of the request topic request-topic=OUTGOING_MESSAGES
    • The name of the response topic response-topic=INCOMING_RESPONSES
    • The directory where files are created before sending to HIP data-directory=/tmp
    • For SSL enabled authentication, set the following properties:
      security.ssl=true
      # For kerberos, use protocol as SASL_PLAINTEXT
      security.protocol=SSL
      ssl.truststore.location=/data/config/kafka.client.truststore.jks
      ssl.truststore.password=hcl2020
      
      security.authentication =username
      ssl.keystore.location=/data/config/kafka.client.keystore.jks
      ssl.keystore.password=hcl2020
      ssl.key.password=hcl2020
      ssl.endpoint.identification.algorithm=
    • For SASL plaintext related enabled authentication, set the following properties:
      security.ssl=false
      security.sasl=true
      security.protocol=SASL_PLAINTEXT
      sasl.mechanism=PLAIN
      security.sasl.auth.login.config =<Path for kafka_client_jaas.conf>

      Example: If folder path for kafka_client_jaas.conf is /opt then security.sasl.auth.login.config=opt/kafka_client_jaas.conf

      Please note that the contents of kafka_client_jaas.conf should be like this for example:
      KafkaClient
      { org.apache.kafka.common.security.plain.PlainLoginModule required username="xxxxx" password="xxxxx"; };
    • For Kerberos enabled authentication, set the following properties:
      security.sasl=true
      sasl.mechanism=GSSAPI
      sasl.kerberos.service.name=kafka
      security.sasl.auth.login.config=
      # Either specify the location JAAS configuration file in the above property or
      # provide the configurations directly in the below property.
      sasl.jaas.config=
      # Specify the location of krb5 configuration file
      java.security.krb5.conf=
  3. Update the platform.properties file located under <link_install>/integration-context/apps. Set the following properties:
    • Set the base URL of the Unica Platform server. For example: http://myserver:7001. Do not specify a slash (/) after the URL.
    • base_url=http://IPADDRESS:<PORT>
    • Credentials: username=asm_admin password=password