| | |
|---|
| | | package com.fzzy.gateway.hx2023.kafka; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.fzzy.gateway.hx2023.data.GrainData; |
|---|
| | | import com.fzzy.gateway.hx2023.data.KafaGrainData; |
|---|
| | | |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | |
|---|
| | | import org.apache.kafka.clients.consumer.ConsumerRecord; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.kafka.annotation.KafkaListener; |
|---|
| | | import org.springframework.kafka.core.KafkaTemplate; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | |
|---|
| | | * @param data |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public String sendGrainData2Cloud(GrainData data) { |
|---|
| | | public String sendGrainData2Cloud(KafaGrainData data) { |
|---|
| | | |
|---|
| | | |
|---|
| | | String strData = JSONObject.toJSONString(data); |
|---|
