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 }