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

  1. 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`

  2. 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. }}
  3. 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
  4. Restart OI server.