kafka

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

type ChannelConfig struct {
	TopicGroup        string
	NumPartitions     int
	ReplicationFactor int
}

type Manager struct {
	Host        string
	ConnFactory func(host string) (*kafka.Conn, error)
}

type ReaderInterface interface {
	FetchMessage(ctx context.Context) (kafka.Message, error)
	CommitMessages(ctx context.Context, messages ...kafka.Message) error
}

type WriterInterface interface {
	WriteMessages(ctx context.Context, messages ...kafka.Message) error
}