We have upgraded our Pega application from 7.4 to 8.51. We use internal cloud for hosting. In development region we have 2 VM.
We have our agents, listeners running in BackgroundProcessing. Reason for classifying Search and Stream on both the nodes is performance related. When we start the app, the Search is getting indexed randomly in any of the nodes.
Decisioning -> Infrastructure -> Services -> Stream shows both the VMs running and NORMAL status. I didnot configure anything specific for Kafka.
How do I confirm Kafka is configured properly and working fine? Please Guide
***Edited by Moderator: Pooja Gadige to change content format from Discussion to Question, add platform capability tag***
When you label any jvm with Node type as "Stream", during Start up, Pega will start the Kafka Services on that particular jvm. It is handled by Pega, you do not need to do any special configuration for this need.
Couple ways you an make sure:
#1. In your temp directory, Kafkadata folder should have the latest information
#2. Upon clicking on any Stream Nodes from Decisioning landing Page, Under Partition section, any given jvm Should be Leader for half of the total partition. Please see attached screenshot
#3.In case of any issues Stream Nodes joining the Cluster, look at the PegaCLUSTER logs along with a file generated from "Show diagnostics"