Browse Source

Merge branch 'dev' into 'mp-server-test'

消息消费异常

See merge request quanshu/mp-server!152
zhong chunping 3 years ago
parent
commit
43ca116fee

+ 1 - 1
mp-common/src/main/java/com/qs/mp/common/pulsar/PulsarClientService.java

@@ -97,7 +97,7 @@ public class PulsarClientService {
           logger.info("receive data>>>>>>" + jsons);
           logger.info("receive data>>>>>>" + jsons);
           consumer.acknowledge(message);
           consumer.acknowledge(message);
         } catch (Exception e) {
         } catch (Exception e) {
-          LogUtil.error(logger, "消费Pulsar数据异常,key【{}】,json【{}】:", message.getKey(), jsons, e);
+          LogUtil.error(logger, e, "消费Pulsar数据异常,key【{0}】,json【{1}】:", new Object[]{message.getKey(), jsons});
         }
         }
       }
       }