producer

type KafkaProducerConfig struct {
	BrokerUrls []string
	ClientID   string
}

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

type TransactionProducer interface {
	Produce(ctx context.Context, queueName string, transaction consumer.TransactionDTO) error
	Close() error
}