导读:本博文重点介绍了生产者发送消息是怎么发得，发送得流程又是什么，生产者配置有哪些常见得配置，代码异步调用得时候怎么知道有没有异常，消息怎么顺序发送和kafka自定义分区规则，让你知其然再知其所以然。

回调验签流程介绍官方文档 https://pay.weixin.qq.com/wiki/doc/apiv3/apis/chapter3_4_5.shtmlhttps://pay.weixin.qq.com/wiki/doc/apiv3/wechatpay/wechatpay4_1.shtml注意:同样的通知可能会多次发送给商户系统，商户系统必须能够正确处理重复的通知确保回调URL是外部可正常访问的

idea导入springboot项目，启动类有红叉

The Bean Validation API is on the classpath but no implementation could be foundAction:Add an implementation, such as Hibernate Validator, to the classpath

es重建索引步骤

一、Kafka命令行生产者发送消息和消费者消费消息创建topic./kafka-topics.sh --create --zookeeper xx.xx.xx.160:2181 --replication-factor 1 --partitions 2 --topic wnn-topic•查看topic./kafka-topics.sh --list --zookeeper xx.xx.xx.16

es根据ids批量删除结果