kafka

type Consumer interface {
	// Subscribe consumes the events of a topic and passes the event to the
	// informed callback function. The method call blocks until an error occurs.
	// The program may also specify a context to asynchronously cancel the blocking operation.
	Subscribe(ctx context.Context, callbackFn func(event *Event, err error))

	// Close closes the stream, preventing the program from reading any more
	// events from it.
	Close()
}

type Event struct {
	Topic  string
	Key    []byte
	Value  []byte
	Header map[string]string
	Time   time.Time
}

type Kafka interface {

	// NewProducer creates a new Producer to produce events on a topic.
	NewProducer(topic string) Producer

	// NewConsumer creates a new Consumer to consume events from a topic.
	NewConsumer(groupID, topic string) Consumer

	// Debug enables logging of incoming events.
	Debug(debug bool)
}

type Producer interface {
	// Publish produces and sends an event for a kafka topic.
	// The context passed as first argument may also be used to asynchronously
	// cancel the operation.
	Publish(ctx context.Context, key []byte, values ...[]byte) error

	// Close flushes pending writes, and waits for all writes to complete before
	// returning.
	Close()
}