|
@@ -97,7 +97,7 @@ public class PulsarClientService {
|
|
|
logger.info("receive data>>>>>>" + jsons);
|
|
|
consumer.acknowledge(message);
|
|
|
} 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});
|
|
|
}
|
|
|
}
|
|
|
|