KafkaSinkCluster: error on AllocateProducerIds

shotover · Nov 10, 2024 · be450e6 · be450e6
1 parent a75cf7f
commit be450e6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/shotover/src/transforms/kafka/sink_cluster/mod.rs b/shotover/src/transforms/kafka/sink_cluster/mod.rs
@@ -988,7 +988,8 @@ impl KafkaSinkCluster {
                     body:
                         RequestBody::LeaderAndIsr(_)
                         | RequestBody::StopReplica(_)
-                        | RequestBody::UpdateMetadata(_),
+                        | RequestBody::UpdateMetadata(_)
+                        | RequestBody::AllocateProducerIds(_),
                     header:
                         RequestHeader {
                             request_api_key, ..