From cb8cf1b618a093f6bb3340330192bb5c06b3da52 Mon Sep 17 00:00:00 2001 From: Lucas Kent Date: Mon, 18 Nov 2024 12:15:11 +1100 Subject: [PATCH] KafkaSinkCluster: error on AlterPartition request (#1817) --- shotover/src/transforms/kafka/sink_cluster/mod.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/shotover/src/transforms/kafka/sink_cluster/mod.rs b/shotover/src/transforms/kafka/sink_cluster/mod.rs index a985d370f..2dec16206 100644 --- a/shotover/src/transforms/kafka/sink_cluster/mod.rs +++ b/shotover/src/transforms/kafka/sink_cluster/mod.rs @@ -1051,7 +1051,11 @@ impl KafkaSinkCluster { | RequestBody::UpdateMetadata(_) // It was determined that this message type is only sent between brokers by: // * https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=177049344#KIP730:ProducerIDgenerationinKRaftmode-PublicInterfaces - | RequestBody::AllocateProducerIds(_), + | RequestBody::AllocateProducerIds(_) + // It was determined that this message type is only sent between brokers because: + // * it is not exposed via the Admin client. + // * This KIP discusses the message type and makes no mention of clients using it https://cwiki.apache.org/confluence/display/KAFKA/KIP-704:+Send+a+hint+to+the+partition+leader+to+recover+the+partition + | RequestBody::AlterPartition(_), header: RequestHeader { request_api_key, ..