Pega 8 connectivity to MSK via Public Access and SASL/SCRAM

Pega-as-a-Service
, , ,
1

Hi, Greetings. I am trying to connect to MSK by enabling public access as well as using SASL/SCRAM, i have the below in properties file

security.protocol=SASL_SSL sasl.mechanism=SCRAM-SHA-512 sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \ username=“xxx” \ password=“xx-xxx”;

But i am getting

Could not connect to Kafka, reason: com.pega.dsm.kafka.api.KafkaConnectivityException: Error connecting to Kafka

Is there something i am missing? Can someone please help me with this?

Regards,

Bharat

2

@KOMARINA

We had similar issue recently. To make sure connectivity is there between Pega and Kafka cluster, we got an unauthenticated Kafka cluster created and wrote a simple java snippet to connect to it and ran the same from Activity. With that we found that there are some firewall rules blocking incoming connections on the Kafka cluster side. Once we allowed the connection in Firewall, we are able to connect. I don’t see any problem with the properties file that you have shared. I am attaching the one I used in my configuration.

Thanks,

Santhosh

Sample_Kafkaconnect.properties.txt (178 Bytes)

Kafka_ConnectivityTest.java_.txt (854 Bytes)

3

@SanthoshB16725345 Hi, Similar issue with one of the security groups, once i configured the inbound rule, i was able to connect.

Regards,

Bharat

4

@KOMARINA

Hope you are doing well.

Please can i request you to share step by step to connect local pega instance 24.2 (home server installation) to aws msk.