kafka

type Client interface {
	Reader(ctx context.Context, topicConfig Config) (Reader, error)
	Writer(ctx context.Context, topicConfig Config) (Writer, error)
}

type Config struct {
	Topic            string
	BootstrapServers []string
}

type Logger interface {
	Info(ctx context.Context, msg string, keysAndValues ...interface{})
	Error(ctx context.Context, msg string, keysAndValues ...interface{})
}

type Message struct {
	Key       string
	Headers   map[string]string
	Offset    int32
	Partition int32
	// contains filtered or unexported fields
}

type Reader interface {
	Read(ctx context.Context) (*Message, error)
}

type Response struct {
	Partition int32
	Offset    int64
}

type Writer interface {
	Write(ctx context.Context, key string, value []byte) (Response, error)
}