在 yarn-site.xml 中设置 yarn.scheduler.fair.allow-undeclared-pools ，将它的值配置为 false （默认是 true ）。

理论上微服务只要配置了重试机制写入接口都需要考虑幂等性。因为需要考虑网络的抖动，数据包会重复提交，如果没有幂等性就会出现脏数据了。使用消息队列也需要使用幂等性，因为消费端可能在某个环节失败后没有commit，导致消息会再次投递的。...

在高并发的场景下，缓存、队列，异步是必备的技术手段，在哪里使用缓存，这个没有一个标准的方案，但是有个约定的前提，谁提供谁负责（谁提供的服务，谁来保障服务的高可用）。这里给下我的建议：1、一切皆缓存，所有的地方都可以用缓存，如果担心因为缓存更新策略问题带来的数据不一致，那么可以...

你这是找到了问题的源头，但是为了避免因为错误消息而堵塞队列，还是建议设置死信队列。回复 16# chkang