()
| 8 | ) |
| 9 | |
| 10 | func init() { |
| 11 | // Register a type override so that raw produce requests will be encoded with the correct type. |
| 12 | req := &Request{} |
| 13 | protocol.RegisterOverride(req, &produce.Response{}, req.TypeKey()) |
| 14 | } |
| 15 | |
| 16 | type Request struct { |
| 17 | TransactionalID string `kafka:"min=v3,max=v8,nullable"` |
nothing calls this directly
no test coverage detected