streaming

type ConsumerHandler func(message Message) error

type Header struct {
	Key   string
	Value []byte
}

type Message struct {
	Topic         string
	Partition     int
	Offset        int64
	HighWaterMark int64
	Key           []byte
	Value         []byte
	Headers       []Header
	Time          time.Time
}

type Streaming interface {
	Producer(ctx context.Context, topic string, value []byte) (err error)
	Consumer(ctx context.Context, topic string, handler ConsumerHandler) (err error)
}