NewAsyncProducer instantiates a new Producer mock.

NewConsumer returns a new mock Consumer instance.

NewSyncProducer instantiates a new SyncProducer mock.

AsyncProducer implements sarama's Producer interface for testing purposes.

Consumer implements sarama's Consumer interface for testing purposes.

PartitionConsumer implements sarama's PartitionConsumer interface for testing purposes.

SyncProducer implements sarama's SyncProducer interface for testing purposes.

ErrorReporter is a simple interface that includes the testing.T methods we use to report expectation violations when using the mock objects.

ValueChecker is a function type to be set in each expectation of the producer mocks to check the value passed.