Function TestConsumerMeetsErrorsDrainedExpectation

mocks/consumer_test.go:254–279

(t *testing.T)

}

func TestConsumerMeetsErrorsDrainedExpectation(t *testing.T) {
	trm := newTestReporterMock()
	consumer := NewConsumer(trm, NewTestConfig())

	consumer.ExpectConsumePartition("test", 0, sarama.OffsetOldest).
		YieldError(sarama.ErrInvalidMessage).
		YieldError(sarama.ErrInvalidMessage).
		ExpectErrorsDrainedOnClose()

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

	// consume first and second error,
	<-pc.Errors()
	<-pc.Errors()

	if err := consumer.Close(); err != nil {
		t.Error(err)
	}

	if len(trm.errors) != 0 {
		t.Errorf("Expected no expectation failures to be set on the error reporter.")
	}
}

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