first commit

whycxzp

2023-05-11 b0c4d3f59557206ee88ae5af43f4c835e0060149

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
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);
    }
 
 
}