Error on UnregisterBroker

shotover · Nov 18, 2024 · a905fc0 · a905fc0
1 parent e50d528
commit a905fc0
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
@@ -1099,6 +1099,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."
                     ));
                 }