// Code generated by gen. DO NOT EDIT.
package app

import (
	"joybuywork/internal/config"
	"gits.branchcn.com/backend/microcode/plugins/kafka"
)

var Kafka kafka.Plugin

func InitKafka() (err error) {
	kafkaConfig := kafka.PluginConfig{
		Brokers: config.Config.Kafka.Brokers,
	}
	Kafka, err = kafka.NewPlugin(kafkaConfig)
	if err != nil {
		return
	}
	return
}