diff --git a/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java b/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java index 06a1e4e7..1f6a98bd 100644 --- a/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java +++ b/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java @@ -319,7 +319,7 @@ public class GoodsMessageListener implements RocketMQListener { } } } - goodsIndexService.updateBulkIndex(goodsIndices); + goodsIndexService.addIndex(goodsIndices); }