KafkaSinkCluster: error on AlterPartition request (#1817)

shotover · Nov 18, 2024 · cb8cf1b · cb8cf1b
1 parent 3a37288
commit cb8cf1b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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, ..