package com.whyc.config;

import com.alibaba.fastjson2.JSON;
import com.whyc.dto.Response;
import com.whyc.dto.interfaceC.DataC;
import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.KafkaListener;

@Configuration
public class KafkaConfig {

    @Bean
    public NewTopic batchTopic() {
        //return new NewTopic("topic_device_data",3,(short)3);
        return new NewTopic("topic_device_data2",1,(short)1);
    }

    //@KafkaListener(topics = "topic_device_data")
    public void consumerTopic(String data){
        DataC dataC = JSON.parseObject(data, DataC.class);
        System.out.println(dataC);
    }


}