Error on UnregisterBroker (#1820)

shotover · Nov 19, 2024 · 3f76b54 · 3f76b54
1 parent 73ac04c
commit 3f76b54
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/shotover/src/transforms/kafka/sink_cluster/mod.rs b/shotover/src/transforms/kafka/sink_cluster/mod.rs
@@ -1101,6 +1101,17 @@ The connection to the client has been closed."#
                     return Err(anyhow!(
                         "Client sent ControlledShutdown request.
 Shotover cannot handle this request as it is not appropriate for shotover to shutdown.
+The connection to the client has been closed."
+                    ));
+                }
+                Some(Frame::Kafka(KafkaFrame::Request {
+                    body: RequestBody::UnregisterBroker(_),
+                    ..
+                })) => {
+                    // This message types is a replacement for ControlledShutdown so the same reasoning applies.
+                    return Err(anyhow!(
+                        "Client sent UnregisterBroker request.
+Shotover cannot handle this request as it is not appropriate for shotover to shutdown.
 The connection to the client has been closed."
                     ));
                 }