mock

type KafkaConsumer struct {
	ReadMessageFn      func(time.Duration) (*ck.Message, error)
	ReadMessageInvoked bool

	SubscribeFn      func(string, ck.RebalanceCb) error
	SubscribeInvoked bool

	SubscribeTopicsFn      func([]string, ck.RebalanceCb) error
	SubscribeTopicsInvoked bool

	SeekFn      func(ck.TopicPartition, int) error
	SeekInvoked bool

	CommitMessageFn      func(*ck.Message) ([]ck.TopicPartition, error)
	CommitMessageInvoked bool

	PauseFn      func([]ck.TopicPartition) (err error)
	PauseInvoked bool

	ResumeFn      func([]ck.TopicPartition) (err error)
	ResumeInvoked bool

	CloseFn      func() error
	CloseInvoked bool
}

type KafkaProducer struct {
	CloseFn      func()
	CloseInvoked bool

	ProduceFn      func(*ck.Message, chan ck.Event) error
	ProduceInvoked bool
}