From 3f76b54965f830fac8fb9802ea54b31e7f711e0b Mon Sep 17 00:00:00 2001 From: Lucas Kent Date: Tue, 19 Nov 2024 11:05:43 +1100 Subject: [PATCH] Error on UnregisterBroker (#1820) --- shotover/src/transforms/kafka/sink_cluster/mod.rs | 11 +++++++++++ 1 file changed, 11 insertions(+) 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." )); }