Skip to main content

This content has been archived and is no longer being updated. Links may not function; however, this content may be relevant to outdated versions of the product.

Support Article

Data Flow Run pzStandardProcessor fails, Kafka lag



The Run Data Flow step's use of Queue Processor rule pzStandardProcessor throws the on-screen error and log error.


Error Messages


Unable to calculate Kafka lag for PZSTANDARDPROCESSOR, environment stateClusterDescription
Run is currently on unexpected Initializing state


Steps to Reproduce



Root Cause

The state of Kafka changed to Blocked after the number of nodes was changed from 2 to 1. The Stream service did not support automatic scaling when the number of nodes was decreased.


Perform the following local-change:
Decommission and re-add the util node to the Stream service


Published January 31, 2019 - Updated December 2, 2021

Was this useful?

0% found this useful

Have a question? Get answers now.

Visit the Collaboration Center to ask questions, engage in discussions, share ideas, and help others.

Did you find this content helpful?

Want to help us improve this content?

We'd prefer it if you saw us at our best.

Pega Community has detected you are using a browser which may prevent you from experiencing the site as intended. To improve your experience, please update your browser.

Close Deprecation Notice
Contact us