kafka

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

type Processor interface {
	Process(ctx context.Context, msg []byte) error
}

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

type Reader interface {
	FetchMessage(ctx context.Context) (kafka.Message, error)
	CommitMessages(ctx context.Context, msgs ...kafka.Message) error
	Close() error
}

type Writer interface {
	WriteMessages(ctx context.Context, msgs ...kafka.Message) error
}