不调用业务,全部消费掉消息
This commit is contained in:
@@ -63,8 +63,7 @@ public class NameplateKafkaConsumer {
|
|||||||
log.info("nameplateKafkaConsumerMessage,不满足条件");
|
log.info("nameplateKafkaConsumerMessage,不满足条件");
|
||||||
}
|
}
|
||||||
|
|
||||||
tmNameplateCorpus.getData().forEach(nameplate ->
|
|
||||||
tmNameplateCorpusService.processItem(nameplate));
|
|
||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("处理消息失败", e);
|
log.error("处理消息失败", e);
|
||||||
|
|||||||
Reference in New Issue
Block a user