(t *testing.T, ctx context.Context, r *Reader)
| 660 | } |
| 661 | |
| 662 | func testConsumerGroupSimple(t *testing.T, ctx context.Context, r *Reader) { |
| 663 | if err := r.Close(); err != nil { |
| 664 | t.Fatalf("bad err: %v", err) |
| 665 | } |
| 666 | } |
| 667 | |
| 668 | func TestReaderSetOffsetWhenConsumerGroupsEnabled(t *testing.T) { |
| 669 | r := &Reader{config: ReaderConfig{GroupID: "not-zero"}} |