Function TestConsumerReturnsNonconsumedErrorsOnClose

mocks/consumer_test.go:150–176

(t *testing.T)

}

func TestConsumerReturnsNonconsumedErrorsOnClose(t *testing.T) {
	consumer := NewConsumer(t, NewTestConfig())
	consumer.ExpectConsumePartition("test", 0, sarama.OffsetOldest).YieldError(sarama.ErrOutOfBrokers)
	consumer.ExpectConsumePartition("test", 0, sarama.OffsetOldest).YieldError(sarama.ErrOutOfBrokers)

	pc, err := consumer.ConsumePartition("test", 0, sarama.OffsetOldest)
	if err != nil {
		t.Fatal(err)
	}

	select {
	case <-pc.Messages():
		t.Error("Did not expect a message on the messages channel.")
	case err := <-pc.Errors():
		if !errors.Is(err, sarama.ErrOutOfBrokers) {
			t.Error("Expected sarama.ErrOutOfBrokers, found", err)
		}
	}

	var errs sarama.ConsumerErrors
	if !errors.As(pc.Close(), &errs) {
		t.Error("Expected Close to return ConsumerErrors")
	}
	if len(errs) != 1 && !errors.Is(errs[0], sarama.ErrOutOfBrokers) {
		t.Error("Expected Close to return the remaining sarama.ErrOutOfBrokers")
	}
}

func TestConsumerWithoutExpectationsOnPartition(t *testing.T) {
	trm := newTestReporterMock()