@KafkaListener(topics = "goodskill-kafka")
    public void onMessage(Object data) {
        if (data instanceof ConsumerRecord record) {
            String userPhone = record.key().toString();
            String value = (String) record.value();
            SeckillMockRequestDTO seckillMockRequestDTO;
            if (StringUtils.hasText(value)) {
                seckillMockRequestDTO = JSON.parseObject(value, SeckillMockRequestDTO.class);
                seckillExecutor.dealSeckill(seckillMockRequestDTO.getSeckillId(), userPhone, "秒杀场景四(kafka消息队列实现)", seckillMockRequestDTO.getTaskId());
            }
        } else {
            log.warn("未处理数据：{}", data.toString());
        }
    }
@Test
    public void onMessage() {
        SeckillMockRequestDTO seckillMockRequestDTO = new SeckillMockRequestDTO();
        seckillMockRequestDTO.setSeckillId(1001L);
        seckillKafkaConsumer.onMessage(new ConsumerRecord("1", 1, 0L, "key", JSON.toJSONString(seckillMockRequestDTO)));
        verify(seckillExecutor, only()).dealSeckill(anyLong(),any(),any(), any());
    }