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