base/frameworks/broker/backpressure.zeek

This handles Broker peers that fall so far behind in handling messages that this node sends it that the local Broker endpoint decides to unpeer them. Zeek captures this as follows:

  • In broker.log, with a regular “peer-removed” entry indicating CAF’s reason.

  • Via eventing through Broker::peer_removed as done in this script.

The cluster framework additionally captures the unpeering as follows:

  • In cluster.log, with a higher-level message indicating the node names involved.

  • Via telemetry, using a labeled counter.

Summary

Detailed Interface