(t *testing.T)
| 700 | } |
| 701 | |
| 702 | func TestReaderPartitionWhenConsumerGroupsEnabled(t *testing.T) { |
| 703 | invoke := func() (boom bool) { |
| 704 | defer func() { |
| 705 | if r := recover(); r != nil { |
| 706 | boom = true |
| 707 | } |
| 708 | }() |
| 709 | |
| 710 | NewReader(ReaderConfig{ |
| 711 | GroupID: "set", |
| 712 | Partition: 1, |
| 713 | }) |
| 714 | return false |
| 715 | } |
| 716 | |
| 717 | if !invoke() { |
| 718 | t.Fatalf("expected panic; but NewReader worked?!") |
| 719 | } |
| 720 | } |
| 721 | |
| 722 | func TestExtractTopics(t *testing.T) { |
| 723 | testCases := map[string]struct { |
nothing calls this directly
no test coverage detected