Question
Anthem inc
US
Last activity: 6 Oct 2025 9:57 EDT
How to parameterize Kafka rule and Kafka data set ?
We have a Kafka topic crated in lower environment. Updated the server with the required detail such a jaas, keystore, Kerberos files specific to lower environment.
Can we give the host name and port dynamically with environment specific.
kada date will have the name go the Kafka rule. Once test connectivity is established only the dropdown of topic in the Kafka server are shown. How can we pass the topic name of higher environments.
thank you in advance
@venkatasahithp6252 To parameterize the Kafka rule and Kafka dataset in Pega, you can use environment-specific dynamic system settings or environment variables to store the Kafka host name, port, and topic names. Instead of hardcoding the server details in the Kafka data set or rule, create DSS (Dynamic System Settings) like
KafkaHost_QA,KafkaPort_UAT, andKafkaTopic_PRODand refer to them usingGlobalResourceSettingsin the Kafka configuration. This way, you can keep the same rule and dynamically load values based on the environment. When connecting to the Kafka server, ensure the JAAS, keystore, and Kerberos files are also picked based on environment settings or mounted correctly in the cloud setup. For the topic list to appear in the dropdown, the Kafka rule must first test connectivity successfully; but even if the topic isn't listed, you can manually enter the topic name from the DSS or parameter using=DSS.TopicName. This allows deploying the same rule across environments without manual edits. Please let me know if you need any more info. Thanks