Revert "add more tagged fields"

This reverts commit 5b5b590.

Author: petedannemann

protocol/alterclientquotas/alterclientquotas.go

@@ -22,28 +22,19 @@ func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) {
 }
 
 type Entry 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"`
 	Ops      []Ops    `kafka:"min=v0,max=v1"`
 }
 
 type Entity struct {
-	// 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"`
+	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 Ops struct {
-	// 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"`
-	Remove bool     `kafka:"min=v0,max=v1"`
+	Key    string  `kafka:"min=v0,max=v0|min=v1,max=v1,compact"`
+	Value  float64 `kafka:"min=v0,max=v1"`
+	Remove bool    `kafka:"min=v0,max=v1"`
 }
 
 type Response struct {
@@ -57,9 +48,6 @@ type Response struct {
 func (r *Response) ApiKey() protocol.ApiKey { return protocol.AlterClientQuotas }
 
 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"`
 	ErrorCode    int16    `kafka:"min=v0,max=v1"`
 	ErrorMessage string   `kafka:"min=v0,max=v1,nullable"`
 	Entities     []Entity `kafka:"min=v0,max=v1"`

protocol/describeclientquotas/describeclientquotas.go

@@ -21,12 +21,9 @@ func (r *Request) Broker(cluster protocol.Cluster) (protocol.Broker, error) {
 }
 
 type Component struct {
-	// 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"`
+	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 {
@@ -42,25 +39,16 @@ type Response struct {
 func (r *Response) ApiKey() protocol.ApiKey { return protocol.DescribeClientQuotas }
 
 type Entity struct {
-	// 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"`
+	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 {
-	// 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"`
+	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"`
 }