(t *testing.T)
| 109 | } |
| 110 | |
| 111 | func TestNormalOffsetCommitResponse(t *testing.T) { |
| 112 | response := OffsetCommitResponse{} |
| 113 | response.AddError("t", 0, ErrNotLeaderForPartition) |
| 114 | response.Errors["m"] = make(map[int32]KError) |
| 115 | // The response encoded form cannot be checked for it varies due to |
| 116 | // unpredictable map traversal order. |
| 117 | testResponse(t, "normal", &response, nil) |
| 118 | } |
| 119 | |
| 120 | func TestOffsetCommitResponseWithThrottleTime(t *testing.T) { |
| 121 | for version := 3; version <= 4; version++ { |
nothing calls this directly
no test coverage detected