cmhi
/
dispose
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

OCT 

REM:
1. 删除冗余代码
This commit is contained in:
chenlinghy 2021-09-07 15:38:22 +08:00
parent 5af36c1ac3
commit 17655252ff
1 changed files with 0 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/com/dispose/controller/kafkaController.java
View File

@ -52,8 +52,6 @@ public class kafkaController {
/** /**
* The Kafka configuration. * The Kafka configuration.
*/ */
// final private KafkaConfiguration kafkaConfiguration =
// SpringBootBeanUtil.getBean(com.dispose.config.KafkaConfiguration.class);
@Resource @Resource
private KafkaConfiguration kafkaConfiguration; private KafkaConfiguration kafkaConfiguration;
@ -92,17 +90,4 @@ public class kafkaController {
rspInfo.setMessage(new String[]{ErrorCode.ERR_OK.getMsg()}); rspInfo.setMessage(new String[]{ErrorCode.ERR_OK.getMsg()});
return ProtocolRespDTO.result(ErrorCode.ERR_OK, rspInfo); return ProtocolRespDTO.result(ErrorCode.ERR_OK, rspInfo);
} }
// @KafkaListener(topics = {"ddos-vip-customer-ck"})
// public void kafkaListen(ConsumerRecord<String, String> consumerRecord) {
// //判断消息是否为null
// Optional<String> kafkaMessage = Optional.ofNullable(consumerRecord.value());
// log.info(">>>>>>>>>>> record = " + kafkaMessage);
// if (kafkaMessage.isPresent()) {
// String consumerMsg = kafkaMessage.get();
// log.info("消费消息：" + consumerMsg);
// }
// }
} }