(t *testing.T)
| 226 | } |
| 227 | |
| 228 | func TestOffsetFetchRequestAddGroupPartition(t *testing.T) { |
| 229 | t.Run("creates a new group entry", func(t *testing.T) { |
| 230 | request := &OffsetFetchRequest{Version: 8} |
| 231 | request.AddGroupPartition("g1", "t1", 0) |
| 232 | |
| 233 | require.Len(t, request.Groups, 1) |
| 234 | assert.Equal(t, "g1", request.Groups[0].GroupId) |
| 235 | assert.Equal(t, []int32{0}, request.Groups[0].Partitions["t1"]) |
| 236 | }) |
| 237 | |
| 238 | t.Run("appends to an existing group entry", func(t *testing.T) { |
| 239 | request := &OffsetFetchRequest{ |
| 240 | Version: 8, |
| 241 | Groups: []OffsetFetchRequestGroup{ |
| 242 | {GroupId: "g1", Partitions: map[string][]int32{"t1": {0}}}, |
| 243 | }, |
| 244 | } |
| 245 | request.AddGroupPartition("g1", "t1", 1) |
| 246 | request.AddGroupPartition("g1", "t2", 7) |
| 247 | request.AddGroupPartition("g2", "t3", 2) |
| 248 | |
| 249 | require.Len(t, request.Groups, 2) |
| 250 | assert.Equal(t, "g1", request.Groups[0].GroupId) |
| 251 | assert.Equal(t, []int32{0, 1}, request.Groups[0].Partitions["t1"]) |
| 252 | assert.Equal(t, []int32{7}, request.Groups[0].Partitions["t2"]) |
| 253 | assert.Equal(t, "g2", request.Groups[1].GroupId) |
| 254 | assert.Equal(t, []int32{2}, request.Groups[1].Partitions["t3"]) |
| 255 | }) |
| 256 | } |
| 257 | |
| 258 | func TestOffsetFetchRequestAllPartitions(t *testing.T) { |
| 259 | for version := 2; version <= 5; version++ { |
nothing calls this directly
no test coverage detected