Queue-For-Processing - How can I access the kafka data instance
Hi,
I'm using Queue-For-Processing to push a json asynchronously to AWS, when I read about Queue-For-Processing pega docs says "The system queues the page to the embedded Kafka data instance"
This info can be found here under "Results" section - https://docs-previous.pega.com/system-administration/86/queue-processing-method
Does Pega clean's up the data stored in this Kafka data instance after the json files are delivered to AWS?
Where is this data instance in Pega and how can I access it?
Bentego
TR
Hello @KannanM3
"Does Pega clean's up the data stored in this Kafka data instance after the json files are delivered to AWS?"
I think yes it does clean up the queued and successfully processed item(s).
In case items' status either scheduled (delayed) or broken, you may access item instances from the Pega platform's OOTB classes below.
- System-Message-QueueProcessor-BrokenItem
- System-Message-QueueProcessor-DelayedItem
In addition, as per my study pzDelayedQueueProcessorSchedule OOTB job scheduler is pushing for processing the scheduled (delayed) items (probably reading from the database table mapped with System-Message-QueueProcessor-DelayedItem to push Kafka and processing it).
If this piece of information is useful for you, let me know the result.
Regards.
Mert.
NCS Pte. Ltd
SG
Hi @KannanM3: Can you please refer this page which gives most details regarding queue-for-processing. https://docs-previous.pega.com/system-administration/87/queue-processor-faq.
Thanks.