(t *testing.T)
| 89 | } |
| 90 | |
| 91 | func TestOffsetCommitRequestV2ToV4(t *testing.T) { |
| 92 | for version := 2; version <= 4; version++ { |
| 93 | request := new(OffsetCommitRequest) |
| 94 | request.ConsumerGroup = "foobar" |
| 95 | request.ConsumerID = "cons" |
| 96 | request.ConsumerGroupGeneration = 0x1122 |
| 97 | request.RetentionTime = 0x4433 |
| 98 | request.Version = int16(version) |
| 99 | testRequest(t, fmt.Sprintf("no blocks v%d", version), request, offsetCommitRequestNoBlocksV2) |
| 100 | |
| 101 | request.AddBlock("topic", 0x5221, 0xDEADBEEF, 0, "metadata") |
| 102 | testRequest(t, fmt.Sprintf("one block v%d", version), request, offsetCommitRequestOneBlockV2) |
| 103 | } |
| 104 | } |
| 105 | |
| 106 | var ( |
| 107 | offsetCommitRequestOneBlockV5 = []byte{ |
nothing calls this directly
no test coverage detected