| 7 | } |
| 8 | |
| 9 | type Request struct { |
| 10 | // We need at least one tagged field to indicate that this is a "flexible" message |
| 11 | // type. |
| 12 | _ struct{} `kafka:"min=v3,max=v3,tag"` |
| 13 | |
| 14 | TransactionalID string `kafka:"min=v0,max=v2|min=v3,max=v3,compact"` |
| 15 | GroupID string `kafka:"min=v0,max=v2|min=v3,max=v3,compact"` |
| 16 | ProducerID int64 `kafka:"min=v0,max=v3"` |
| 17 | ProducerEpoch int16 `kafka:"min=v0,max=v3"` |
| 18 | GenerationID int32 `kafka:"min=v3,max=v3"` |
| 19 | MemberID string `kafka:"min=v3,max=v3,compact"` |
| 20 | GroupInstanceID string `kafka:"min=v3,max=v3,compact,nullable"` |
| 21 | Topics []RequestTopic `kafka:"min=v0,max=v3"` |
| 22 | } |
| 23 | |
| 24 | type RequestTopic struct { |
| 25 | // We need at least one tagged field to indicate that this is a "flexible" message |
nothing calls this directly
no outgoing calls
no test coverage detected