@Operation(summary = "秒杀场景四(kafka消息队列实现)")
    @PostMapping("/kafka")
    public Result doWithKafkaMqMessage(@RequestBody @Valid SeckillWebMockRequestDTO dto) {
        processSeckill(dto, KAFKA_MQ, () -> {
            String phoneNumber = String.valueOf(SECKILL_PHONE_NUM_COUNTER.incrementAndGet());
            String taskId = String.valueOf(stringRedisTemplate.opsForValue().get("SECKILL_TASK_ID_COUNTER"));
            SeckillMockRequestDTO payload = new SeckillMockRequestDTO(dto.getSeckillId(), 1, phoneNumber, taskId);
            kafkaTemplate.send("goodskill-kafka", phoneNumber, JSON.toJSONString(payload));
        });
        return Result.ok();
        //待mq监听器处理完成打印日志，不在此处打印日志
    }
@Test
    void doWithKafkaMqMessage() {
        SeckillWebMockRequestDTO requestDTO = new SeckillWebMockRequestDTO();
        requestDTO.setSeckillId(1L);
        requestDTO.setRequestCount(1);
        SeckillMockRequestDTO any = new SeckillMockRequestDTO();
        any.setSeckillId(1L);
        Result response = seckillMockController.doWithKafkaMqMessage(requestDTO);

        verify(seckillService, times(0)).execute(any(SeckillMockRequestDTO.class), anyInt());
        assertEquals(0, response.getCode());
    }