NewConsumerMock returns a mock for mm_kafka.Consumer.

NewProducerMock returns a mock for mm_kafka.Producer.

ConsumerMock implements mm_kafka.Consumer.

ConsumerMockCloseExpectation specifies expectation struct of the Consumer.Close.

ConsumerMockCloseResults contains results of the Consumer.Close.

ConsumerMockConsumeExpectation specifies expectation struct of the Consumer.Consume.

ConsumerMockConsumeOrigins contains origins of expectations of the Consumer.Consume.

ConsumerMockConsumeParamPtrs contains pointers to parameters of the Consumer.Consume.

ConsumerMockConsumeParams contains parameters of the Consumer.Consume.

ConsumerMockConsumeResults contains results of the Consumer.Consume.

ProducerMock implements mm_kafka.Producer.

ProducerMockCloseExpectation specifies expectation struct of the Producer.Close.

ProducerMockCloseResults contains results of the Producer.Close.

ProducerMockSendMessageExpectation specifies expectation struct of the Producer.SendMessage.

ProducerMockSendMessageOrigins contains origins of expectations of the Producer.SendMessage.

ProducerMockSendMessageParamPtrs contains pointers to parameters of the Producer.SendMessage.

ProducerMockSendMessageParams contains parameters of the Producer.SendMessage.

ProducerMockSendMessageResults contains results of the Producer.SendMessage.