【消息中心】消息中心初步搭建

初级的消息中心准备提供一个统一的消息中心接口，用户通过消息中心可以将消息发送到kafka集群
，然后通过消费去推送企业微信消息，或者企业邮箱

首先框架上使用了spring-kafka 2.5.7.RELEASE，使用了nacos注册中心和配置中心（可根据需要使用）

  
            org.springframework.kafka
            spring-kafka
        

生产者

package com.test.message.controller;

@RestController
@RequestMapping("/message")
public class MessageController {
    private static final Logger log = LoggerFactory.getLogger(MessageController.class);

    @Resource
    private KafkaTemplate kafkaTemplate;

    
    @ApiOperation(value = "发送消息",notes = "发送消息")
    @PostMapping("sendMess