View definition

(*Consumer).ConsumePartition

Defined in github.com/Shopify/sarama/mocks/consumer.go

Description

ConsumePartition implements the ConsumePartition method from the sarama.Consumer interface. Before you can start consuming a partition, you have to set expectations on it using ExpectConsumePartition. You can only consume a partition once per consumer.

ConsumePartition is referenced in 1 repository

github.com/Shopify/sarama