|
kafkaProducer.send(new ProducerRecord<>(this.webLogTopic,webLogJsonString));
|
|
kafkaProducer.send(new ProducerRecord<>(this.webLogTopic,webLogJsonString));
|
|
log.error("发送web访问日志到kafka失败,topic:{},数据为:{},异常为:{}",this.webLogTopic,webLogJsonString,e.toString());
|
|
log.error("发送web访问日志到kafka失败,topic:{},数据为:{},异常为:{}",this.webLogTopic,webLogJsonString,e.toString());
|