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",3,(short)1);
|
}
|
|
//@KafkaListener(topics = "topic_device_data")
|
public void consumerTopic(String data){
|
DataC dataC = JSON.parseObject(data, DataC.class);
|
System.out.println(dataC);
|
}
|
|
|
}
|
