(t *testing.T)
| 666 | } |
| 667 | |
| 668 | func TestReaderSetOffsetWhenConsumerGroupsEnabled(t *testing.T) { |
| 669 | r := &Reader{config: ReaderConfig{GroupID: "not-zero"}} |
| 670 | if err := r.SetOffset(LastOffset); !errors.Is(err, errNotAvailableWithGroup) { |
| 671 | t.Fatalf("expected %v; got %v", errNotAvailableWithGroup, err) |
| 672 | } |
| 673 | } |
| 674 | |
| 675 | func TestReaderOffsetWhenConsumerGroupsEnabled(t *testing.T) { |
| 676 | r := &Reader{config: ReaderConfig{GroupID: "not-zero"}} |