Merge pull request #38 from twmb/raw-req

kcl misc raw-req: trust an input version if one exists

commands/misc/misc.go

@@ -257,6 +257,12 @@ func probeVersion(cl *client.Client) {
 	fmt.Println("Kafka " + v.VersionGuess())
 }
 
+type pinReq struct {
+	kmsg.Request
+}
+
+func (*pinReq) SetVersion(int16) {}
+
 func rawCommand(cl *client.Client) *cobra.Command {
 	var key int16
 	var b int
@@ -269,9 +275,16 @@ func rawCommand(cl *client.Client) *cobra.Command {
 			if req == nil {
 				out.Die("request key %d unknown", key)
 			}
+			req.SetVersion(-1)
 			raw, err := io.ReadAll(os.Stdin)
 			out.MaybeDie(err, "unable to read stdin: %v", err)
 			err = json.Unmarshal(raw, req)
+			// If the raw json specified a Version field, it
+			// overwrote our -1. We want to pin the version to
+			// what the user specified.
+			if req.GetVersion() != -1 {
+				req = &pinReq{req}
+			}
 			out.MaybeDie(err, "unable to unmarshal stdin: %v", err)
 			ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
 			defer cancel()