confluent

type AdminKafkaClient struct {
	*kafka.AdminClient
}

type Adminer interface {
	CreateTopics(ctx context.Context, topics []TopicSpecification, opt ...CreateTopicsAdminOption) error
	Stop()
}

type Consumer interface {
	Start(ctx context.Context, createTopics []TopicSpecification, consumeTopics []string, maxWaitReadTimeout time.Duration, f ProcessEventFunc) (error, ErrChan)
	Stop()
}

type CreateTopicsAdminOption = kafka.CreateTopicsAdminOption

type ErrChan = chan error // read only channel. non block. store error of kafka if not full.

type Event = kafka.Event

type Message = kafka.Message

type ProcessEventFunc = func(*kafka.Consumer, *Message)

type Producer interface {
	Start(ctx context.Context, finishTimeoutFlushInMs int) (chan Event, error)
	Stop()
	Publish(msg *Message) error
	Flush(timeoutFlushInMs int)
}

type TopicPartition = kafka.TopicPartition

type TopicSpecification = kafka.TopicSpecification