event

type Event interface {
	Header() Header
	Key() string
	Value() []byte
}

type Header interface {
	Get(key string) string
	Set(key string, value string)
	Keys() []string
}

type Producer interface {
	io.Closer
	Send(ctx context.Context, msg Event) error
	BatchSend(ctx context.Context, msg []Event) error
}

type Transactional struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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