Hi Stephane, I have code in NiPyAPI[1] for purging all connections in a process group, which was created to easily reset test flows. I expect you could use it as an example to instead inspect connection status to determine capacity issues using some scheduled fetch and analyse process.
I am not aware of a native method inside NiFi for your requirement, but other wiser minds may offer further insight. [1] https://nipyapi.readthedocs.io/en/latest/nipyapi-docs/nipyapi.html#nipyapi.canvas.list_all_connections On Wed, Apr 9, 2025 at 1:29 PM stephane kouajip <stephanekoua...@gmail.com> wrote: > Hi NiFi Community, > > I'm working with Apache NiFi version 1.27.0, and I need help figuring out > how to report or monitor when a queue is full. I want to be able to track > and get alerts if any queue in my NiFi instance reaches its full capacity. > > I’ve looked through the NiFi documentation and community discussions, but > I haven't found a clear approach to monitor the queues effectively. Can > anyone provide advice or best practices for reporting on a full queue? > Specifically, I'm looking for a way to: > > - > > Monitor when a queue reaches its maximum capacity. > - > > Set up alerts or notifications based on queue status. > - > > Log or report this event for monitoring or troubleshooting purposes. > > Any help or pointers would be greatly appreciated. Thanks in advance! >
