kafka

type ClientFactory interface {
	// NewProducer returns a new Producer instance configured with the specified `config`
	NewProducer(config kafka.ConfigMap) (Producer, error)

	// NewConsumer returns a new Consumer instance configured with the specified `config`
	NewConsumer(config kafka.ConfigMap) (Consumer, error)
}

type Consumer interface {
	Subscribe(topic string, rebalanceCb kafka.RebalanceCb) error
	ReadMessage(timeout time.Duration) (*kafka.Message, error)
	Commit() ([]kafka.TopicPartition, error)
	CommitOffsets(offsets []kafka.TopicPartition) ([]kafka.TopicPartition, error)
	Close() error
}

type ErrorEvent = kafka.Error

type Event = kafka.Event

type MessageDeliveredEvent = kafka.Message

type Producer interface {
	Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error
	Flush(timoutMs int) int
	Close()
}