The OI (Open Integration) Server subscribes the event processed by the Kafka Events Collector and process them as Notifications. And the notifications are visible on the Notifications user interface.
Procedure
- On the VMware Telco Cloud Service Assurance control plane node, execute the following:
export CLUSTER_NAME=edge
kubectl -n kafka-edge get secret $CLUSTER_NAME-cluster-ca-cert -o jsonpath='{.data.ca\.crt}' | base64 --decode > ca.crt
kubectl -n kafka-edge get secret $CLUSTER_NAME-cluster-ca-cert -o jsonpath='{.data.ca\.password}' | base64 --decode > ca.password
export CERT_FILE_PATH=ca.crt
export CERT_PASSWORD_FILE_PATH=ca.password
export KEYSTORE_LOCATION=cacerts
export PASSWORD=`cat $CERT_PASSWORD_FILE_PATH`
export CA_CERT_ALIAS=strimzi-kafka-cert
keytool -noprompt -importcert -alias $CA_CERT_ALIAS -file $CERT_FILE_PATH -keystore $KEYSTORE_LOCATION -keypass $PASSWORD -storepass $PASSWORDexport USER_NAME=kafka-scram-sha-512-client-credentials
export SCRAM_PASSWORD_FILE_PATH=user-scram.password
kubectl -n kafka-edge get secret $USER_NAME -o jsonpath='{.data.password}' | base64 --decode > $SCRAM_PASSWORD_FILE_PATH
export SCRAM_PASSWORD=`cat $SCRAM_PASSWORD_FILE_PATH`
- Copy }}{{cacerts{{ file to OI VM, and update the parameters in tcops-kafka-mapper-events.conf, like location of the keystore, enable flag, topic, broker, and so on. }}
- Add credentials obtained in step 1, to client-connect.conf file.
For example:
kafka-edge:edgeKafkaKeyStore:edge:<E-1.0>B42305EAA1D2C61A95BCA056AD38D455CD972106F8A83FD00488F4C7BAD16618
kafka:kafka-edge:kafka-scram-sha-512-client-credentials:<E-1.0>AA82A691027A5131A7D396693E0977FC3DFE6D1BA10904CA0127A72EF51674B0
- Restart OI server.
