add tags to describeclientquotas types

Author: petedannemann

protocol/describeclientquotas/describeclientquotas.go

@@ -21,9 +21,12 @@ func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) {
 }
 
 type Component struct {
-	EntityType string `kafka:"min=v0,max=v1"`
-	MatchType  int8   `kafka:"min=v0,max=v1"`
-	Match      string `kafka:"min=v0,max=v1,nullable"`
+	// We need at least one tagged field to indicate that this is a "flexible" message
+	// type.
+	_          struct{} `kafka:"min=v1,max=v1,tag"`
+	EntityType string   `kafka:"min=v0,max=v1"`
+	MatchType  int8     `kafka:"min=v0,max=v1"`
+	Match      string   `kafka:"min=v0,max=v1,nullable"`
 }
 
 type Response struct {
@@ -39,16 +42,25 @@ type Response struct {
 func (r *Response) ApiKey() protocol.ApiKey { return protocol.DescribeClientQuotas }
 
 type Entity struct {
-	EntityType string `kafka:"min=v0,max=v0|min=v1,max=v1,compact"`
-	EntityName string `kafka:"min=v0,max=v0,nullable|min=v1,max=v1,nullable,compact"`
+	// We need at least one tagged field to indicate that this is a "flexible" message
+	// type.
+	_          struct{} `kafka:"min=v1,max=v1,tag"`
+	EntityType string   `kafka:"min=v0,max=v0|min=v1,max=v1,compact"`
+	EntityName string   `kafka:"min=v0,max=v0,nullable|min=v1,max=v1,nullable,compact"`
 }
 
 type Value struct {
-	Key   string  `kafka:"min=v0,max=v0|min=v1,max=v1,compact"`
-	Value float64 `kafka:"min=v0,max=v1"`
+	// We need at least one tagged field to indicate that this is a "flexible" message
+	// type.
+	_     struct{} `kafka:"min=v1,max=v1,tag"`
+	Key   string   `kafka:"min=v0,max=v0|min=v1,max=v1,compact"`
+	Value float64  `kafka:"min=v0,max=v1"`
 }
 
 type ResponseQuotas struct {
+	// We need at least one tagged field to indicate that this is a "flexible" message
+	// type.
+	_        struct{} `kafka:"min=v1,max=v1,tag"`
 	Entities []Entity `kafka:"min=v0,max=v1"`
 	Values   []Value  `kafka:"min=v0,max=v1"`
 }