Merge pull request #236 from rmb938/fix235

append partitions and topics to delete records request
twmb · Oct 26, 2022 · fd636b8 · fd636b8
2 parents b605610 + 172c02e
commit fd636b8
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)