Pega 8.5.1 Upgrade Kafka
Hi
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.
1. -DNodeType=WebUser,Search,Stream
2. -DNodeType=BackgroundProcessing,Search,Stream
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
Updated: 24 Mar 2021 14:48 EDT
Ford Motor Company
US
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"