1.SpringMVC整合生产者(Producer)

SpringMVC整合生产者比较简单，我直接用一个单例对象来管理生产者，这样保证生产者也是一个单例对象。

1.1 导入kafka的maven依赖

​

1.2 创建单例对象管理生产者

我使用静态内部类的方式创建单例对象，保证单例对象的线程安全。直接上代码

public class KafkaManager {    private static final Logger LOGGER = LoggerFactory.getLogger(KafkaManager.class);    private static final String BOOTSTRAP_SERVERS = Config.getMqConfig("kafka.bootstrap.servers");    public static final String TOPIC_LOGIN = "Topic_login";    public static final String TOPIC_OLD_API = "Topic_api_use";    public static final String TOPIC_COURSE_VISIT = "Topic_course_visit";    private boolean kafkaAvailable = true;    private KafkaProducer producer;    private KafkaManager() {        this.initManger();    }    private static class SingletonManager {        private static final KafkaManager singletonObj = new KafkaManager();    }    public static