四川网关-提交测试

jiazx0107@163.com

2023-10-31 3f0b65b6b8af5c8c0aa2efa57be3adf2398cd62c

 src/main/java/com/fzzy/gateway/hx2023/kafka/KafkaDeviceReport.java

@@ -6,6 +6,7 @@
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;
@@ -34,7 +35,7 @@


        String strData = JSONObject.toJSONString(data);
        log.debug("----推送粮情信息到云端---{}", strData);
        //log.debug("----推送粮情信息到云端---{}", strData);

        //推送信息
        kafkaTemplate.send("TOPIC_ZLJ_GRAIN_TEMPERATURE", strData).addCallback(success -> {
@@ -45,9 +46,9 @@
            // 消息在分区内的offset
            long offset = success.getRecordMetadata().offset();

            log.info("粮情推送成功:{}-{}-{}-{}", topic, partition, offset, data.getDeviceID());
            log.info("---粮情-->>云端成功:{}-{}-{}-{}", topic, partition, offset, strData);
        }, failure -> {
            log.info("粮情推送失败:{}-{}", data.getDeviceID(), failure.getMessage());
            log.info("---粮情-->>云端失败:{}-{}", data.getDeviceID(), failure.getMessage());
        });

        return "SUCCESS";