We have a queue processor 'pyProcessNotification' not running and about 100k items are in the "Ready to Process" state. How can we delete/clear the queue since we don't want to trigger notifications for old items.
Pega version is 8.3.1
***Edited by Moderator Marissa to update Support Case Details***
I am also facing the issue. I have tried with the code which you shared but i am getting issue with the withTopicName method. Let me know is there any other way to clear the Ready to process queues from Queue Processor.
Error Details are below:
The method withTopicName(String) is undefined for the type StreamDataSetBuilder.
@VVODNALA Items queued to Queue Processors are pushed to Kafka, not database table.
In order to clear the queues, you can try removing the partition directories for your Queue Processor, which are created on the app filesystem. These partitions can be located in the 'kafka-data' directory on each app-node that supports 'Stream' service. For example, kafka-data can be located inside the tomcat installation directory for a Pega app running on tomcat.
Prior to removing the affected partitions from each node separately, ensure the app-servers are stopped to prevent replication between the Stream nodes. Otherwise the Stream service will repopulate the nodes with partition data soon as you remove it from any node within the cluster.