Api/kafka/iconsumer.go

package kafka

import (
	"git.beejay.kim/Craft/Api/service"
	lib "github.com/confluentinc/confluent-kafka-go/v2/kafka"
)

type Consumer interface {
	service.Service
	Subscribe([]string, chan *lib.Message) error
}