diff --git a/src/broker/Manager.cc b/src/broker/Manager.cc
index d7fd09323d..0427aca1e6 100644
--- a/src/broker/Manager.cc
+++ b/src/broker/Manager.cc
@@ -38,6 +38,8 @@
 #include "zeek/iosource/Manager.h"
 #include "zeek/logging/Manager.h"
 #include "zeek/logging/Types.h"
+#include "zeek/plugin/Manager.h"
+#include "zeek/plugin/Plugin.h"
 #include "zeek/telemetry/Manager.h"
 #include "zeek/util.h"
 
@@ -825,6 +827,10 @@ std::vector<broker::peer_info> Manager::Peers() const {
 std::string Manager::NodeID() const { return to_string(bstate->endpoint.node_id()); }
 
 bool Manager::DoPublishEvent(const std::string& topic, cluster::detail::Event& event) {
+    bool do_publish = PLUGIN_HOOK_WITH_RESULT(HOOK_PUBLISH_EVENT, HookPublishEvent(*this, topic, event), true);
+    if ( ! do_publish )
+        return true;
+
     auto maybe_ev = zeek::cluster::detail::to_broker_event(event);
     if ( ! maybe_ev )
         return false;
diff --git a/src/cluster/Backend.cc b/src/cluster/Backend.cc
index cbadf97950..dc0cff5af0 100644
--- a/src/cluster/Backend.cc
+++ b/src/cluster/Backend.cc
@@ -15,6 +15,8 @@
 #include "zeek/cluster/Serializer.h"
 #include "zeek/cluster/cluster.bif.h"
 #include "zeek/logging/Manager.h"
+#include "zeek/plugin/Manager.h"
+#include "zeek/plugin/Plugin.h"
 #include "zeek/util.h"
 
 using namespace zeek::cluster;
@@ -120,6 +122,10 @@ void Backend::DoReadyToPublishCallback(Backend::ReadyCallback cb) {
 bool Backend::DoPublishEvent(const std::string& topic, cluster::detail::Event& event) {
     byte_buffer buf;
 
+    bool do_publish = PLUGIN_HOOK_WITH_RESULT(HOOK_PUBLISH_EVENT, HookPublishEvent(*this, topic, event), true);
+    if ( ! do_publish )
+        return true;
+
     if ( ! event_serializer->SerializeEvent(buf, event) )
         return false;