Cloud Pak for Integration

Hey, I have a IBM ACE 12 application running on on-premise IBM Integration node which send message to Azure Event hub using kafka producer node. The message are successfully passed to Azure Event Hub. 
But when I moved the same application to IBM CP4I running in OpenShift, I am getting below error while sending message to Azure Event Hub.

Error : - 
BIP4362E: Java node error: [BIPmsgs:3893]BIP3893E: The Kafka publish operation by client 'EY' failed because details for topic 'sampeletopic' could not be retrieved from the Kafka server at address 'test-dev-ppe.servicebus.windows.net:9093'. Explanation 'org.apache.kafka.common.errors.TimeoutException: Topic sampeletopic not present in metadata after 5000 ms.'.
The Kafka output connector attempted to retrieve meta-data information for the topic 'sampeletopic' but no response was received. Possible reasons for this are
1) The security configuration or the security credentials are invalid.
2) The topic does not exist.

The security identity of kafka  I created for on-premise Integration Node is below
mqsisetdbparms TESTBRK -n kafka::secedp2ns001::TESTEG -u '$ConnectionString' -p 'Endpoint=sb://test-env-dev.servicebus.windows.net:9093/;SharedAccessKeyName=saspn_test_d;SharedAccessKey=123123kudahbdsuy='

The security identity of kafka  I created for CP4I is below
kafka::secedp2ns001::ir-01-cloudlogs '$ConnectionString' 'Endpoint=sb://test-env-dev.servicebus.windows.net:9093/;SharedAccessKeyName=saspn_test_d;SharedAccessKey=123123kudahbdsuy='


<?xml version="1.0" encoding="UTF-8"?>
<policies>
    <policy policyType="Kafka" policyName="kafkapolicy" policyTemplate="Kafka">
        <bootstrapServers>test-env-dev.servicebus.windows.net:9093</bootstrapServers>
        <securityProtocol>SASL_SSL</securityProtocol>
        <saslMechanism></saslMechanism>
        <sslProtocol>TLSv1.2</sslProtocol>
        <securityIdentity>secedp2ns001::ir-01-cloudlogs</securityIdentity>
        <saslConfig/>
        <sslKeystoreLocation/>
        <sslKeystoreType>JKS</sslKeystoreType>
        <sslKeystoreSecurityIdentity/>
        <sslKeySecurityIdentity/>
        <sslTruststoreLocation/>
        <sslTruststoreType>JKS</sslTruststoreType>
        <sslTruststoreSecurityIdentity/>
        <sslEnableCertificateHostnameChecking>false</sslEnableCertificateHostnameChecking>
        <krbServiceName/>
    </policy>
</policies>