Queue Processesor Error: Failed to prepare partitions

General
, ,
1

Hi All,

I created a dedicated queue processor(delayed) with different processing times for different scenarios

But the queue processor doesn’t seem to be running in the Admin Studio,

when I try to click on the ‘start’ link

I’m facing the error: “Queue processor couldn’t reach a stable state. Please check after some time.”.

Logs shows this error: "DemoQueueProcessesor couldn’t come to a stable state. Status: Initializing "

Data Flow warning : “Failed to prepare partitions”

Also I wasn’t able to find my kafka cluster in the kafka-data in tomcat folder

2

@PoojaP55 I can see multiple previous posts related to this issue but none have accepted solution.

3 scenarios to be checked is:

(i) is QueueProcessor Activity is taking lot of time to execute ?

(ii) Is the stream node is reachable ?

(iii) Sufficient disk space for kafka-data

Please have a looks at below posts if it helps, otherwise better to raise a Pega SR for this issue

3

Thanks @PIYUSHSINHA,

Just found the stream node (Configure → Decisioning → Infrastructure → Services → Stream) was stopped, I executed it again and the queue processor seems to be working fine.