使用spring.cloud.stream来发送kafka消息，并根据某字段将消息发送到固定partition上

1、问题： 在进行功能开发的时候遇到一个需求，具体需求如下： 在某个服务A中接收到消息，对消息体进行校验，判断消息体中的数据是否需要产生告警，若产生告警，则将告警信息发送到kafka中，由另一个服务B接收到消息并记录到mongo中； 当A服务在此接收到消息，发现以前的某个告警已经恢复，则再次发送消息
posted @ 2024-05-10 13:16  烟花火的人生  阅读(16)  评论(0)  编辑  收藏  举报