kcl: fix for minor franz-go breaking change

Maybe the last?

Author: twmb

commands/admin/txn/unhang.go

@@ -149,14 +149,13 @@ func unstick(kcl *client.Client, topic string) {
 				out.Die("fetch errors while looking for stuck partition: %v", errs)
 			}
 			fetches.EachPartition(func(tp kgo.FetchTopicPartition) {
-				p := tp.Partition
-				delete(possibleParts, p.Partition)
-				if p.HighWatermark == p.LastStableOffset {
+				delete(possibleParts, tp.Partition)
+				if tp.HighWatermark == tp.LastStableOffset {
 					return
 				}
 				found = true
-				stuckPartition = p.Partition
-				stuckOffset = p.LastStableOffset
+				stuckPartition = tp.Partition
+				stuckOffset = tp.LastStableOffset
 			})
 		}
 

commands/consume/consume.go

@@ -244,7 +244,7 @@ func (co *consumeOutput) consume() {
 				}
 
 				if co.numPerPartition > 0 {
-					tp := topicPartition{p.Topic, p.Partition.Partition}
+					tp := topicPartition{p.Topic, p.Partition}
 					seen := perPartitionSeen[tp]
 					if seen >= co.numPerPartition {
 						return
@@ -254,7 +254,7 @@ func (co *consumeOutput) consume() {
 				}
 
 				co.num++
-				co.format(r, &p.Partition)
+				co.format(r, &p.FetchPartition)
 
 				if co.num == co.max {
 					os.Exit(0)