manual committing example: fix for kadm change
kadm has some kinks to work out API wise, but until then, we fix this
example.
Fixes
@@ -45,7 +45,7 @@ func main() {
die("unable to fetch group offsets: %v", err)
}
- cl, err := kgo.NewClient(seeds, kgo.ConsumePartitions(os.Into()))
+ cl, err := kgo.NewClient(seeds, kgo.ConsumePartitions(os.Into().Into()))
if err != nil {
die("unable to create client: %v", err)
}
