add throttle time to produce response

protocol/produce_response.go

@@ -22,14 +22,14 @@ func (r *ProduceResponses) Encode(e PacketEncoder) error {
 	for _, r := range r.Responses {
 		e.PutString(r.Topic)
 		e.PutArrayLength(len(r.PartitionResponses))
-
 		for _, p := range r.PartitionResponses {
 			e.PutInt32(p.Partition)
 			e.PutInt16(p.ErrorCode)
 			e.PutInt64(p.BaseOffset)
 			e.PutInt64(p.Timestamp)
 		}
 	}
+	e.PutInt32(r.ThrottleTimeMs)
 	return nil
 }
 
@@ -75,6 +75,10 @@ func (r *ProduceResponses) Decode(d PacketDecoder) error {
 		}
 		resp.PartitionResponses = ps
 	}
+	r.ThrottleTimeMs, err = d.Int32()
+	if err != nil {
+		return err
+	}
 	return nil
 }