Commit c3671cac authored by KeYong's avatar KeYong

清除kafka

parent dbb82fc7
......@@ -333,17 +333,4 @@ public class View3dController extends BaseController {
return CommonResponseUtil.success(msg);
}
// @ApiOperation(value = "kafka消息推送测试", notes = "kafka消息推送测试")
// @PostMapping(value="kafka/send")
// public CommonResponse kafkaMsgSendTest(@RequestParam(name = "topic", required = false) String topic,
// @RequestBody Object msg) {
// try {
// iKafkaProducer.sendMessage(topic, "kafka_msg_test", JSON.toJSONString(msg));
// } catch (Exception e) {
// log.error(e.getMessage(), e);
// return CommonResponseUtil.failure(e.getMessage());
// }
// return CommonResponseUtil.success(msg);
// }
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment