append partitions and topics to delete records request

twmb · Oct 25, 2022 · 172c02e · 172c02e
1 parent b605610
commit 172c02e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/kadm/topics.go b/pkg/kadm/topics.go
@@ -361,7 +361,9 @@ func (cl *Client) DeleteRecords(ctx context.Context, os Offsets) (DeleteRecordsR
 			rp := kmsg.NewDeleteRecordsRequestTopicPartition()
 			rp.Partition = p
 			rp.Offset = o.At
+			rt.Partitions = append(rt.Partitions, rp)
 		}
+		req.Topics = append(req.Topics, rt)
 	}
 
 	shards := cl.cl.RequestSharded(ctx, req)