sonar 解决扫描问题
This commit is contained in:
@@ -53,7 +53,6 @@ public class NameplateKafkaConsumer {
|
||||
NameplateTableKafkaDTO tmNameplateCorpus = JSON.parseObject(recordMessages, NameplateTableKafkaDTO.class);
|
||||
if (!"INSERT".equals(tmNameplateCorpus.getType()) || CollectionUtils.isEmpty(tmNameplateCorpus.getData())) {
|
||||
ack.acknowledge();
|
||||
// 此处应返回 return;
|
||||
}
|
||||
|
||||
tmNameplateCorpus.getData().forEach(nameplate -> tmNameplateCorpusService.processItem(nameplate));
|
||||
|
||||
Reference in New Issue
Block a user