kafka

type Consumer interface {
	Consume(cb func(value []byte) error)
	ConsumeMessage(cb func(value *sarama.ConsumerMessage) error)
	Close()
}

type IOffsetManagerRepo interface {
	ResetPartitionOffset(offset int64)
	GetPartitionNextOffset() (offset int64, err error)
	Close()
}

type OffsetRepo struct {
	// contains filtered or unexported fields
}

type Producer interface {
	Produce(topic string, data []byte, partition int32) error
	Close()
}