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
- Update the kafkalink.properties file located in this location: <link_install>/integration-context/install.
-
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=
-
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