diff --git a/shotover/src/transforms/kafka/sink_cluster/mod.rs b/shotover/src/transforms/kafka/sink_cluster/mod.rs index 5acacd78c..6a4c72a71 100644 --- 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." )); }