Api/kafka/iproducer.go

package kafka

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

type Producer interface {
	service.Service
	Produce(*lib.Message) error
}