消息中心清洗服务

功能：

1.接受message-collect服务采集到的消息，读取清洗映射配置，将上游消息转换为标准cloudevents格式的数据

spec/cloudevents/languages/zh-CN/primer.md at main · cloudevents/spec (github.com)

2.将清洗后的数据入库，并发送到下游kafka队列