feature: 消费原始记录处理

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/consumption/service/impl/XfConsumeDetailOriginalServiceImpl.java

@@ -28,7 +28,6 @@ import java.util.Collection;
  */
 @RequiredArgsConstructor
 @Service
-@DS("storage")
 public class XfConsumeDetailOriginalServiceImpl implements IXfConsumeDetailOriginalService {
 
     private final XfConsumeDetailOriginalMapper baseMapper;

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/mq/KafkaNormalConsumer.java

@@ -62,7 +62,7 @@ public class KafkaNormalConsumer {
 
             HashMap<String, String> headerMap = new HashMap<>();
             headerMap.put("clientId", "e5cd7e4891bf95d1d19206ce24a7b32e");
-            headerMap.put("authorization","Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJsb2dpblR5cGUiOiJsb2dpbiIsImxvZ2luSWQiOiJzeXNfdXNlcjoxMDAiLCJyblN0ciI6IjFGWlpaVVdCNVlScU0xZU1BWW5ZbGJKQnI1Vzh6Z3R2IiwiY2xpZW50aWQiOiJlNWNkN2U0ODkxYmY5NWQxZDE5MjA2Y2UyNGE3YjMyZSIsInRlbmFudElkIjoiMjAyMDA4MTMwNDQ0MTEiLCJ1c2VySWQiOjEwMCwidXNlck5hbWUiOiJhZG1pbiIsImRlcHRJZCI6MTAwLCJkZXB0TmFtZSI6IuS4reWFsea5luWNl-ecgeWnlOWFmuagoea5luWNl-ihjOaUv-WtpumZoiIsImRlcHRUeXBlIjoiMDEifQ.WYs2kJDaU0UQW5WBpQuRzrEPRGrg0io9QTkRrC-XBBI");
+            headerMap.put("authorization","Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJsb2dpblR5cGUiOiJsb2dpbiIsImxvZ2luSWQiOiJzeXNfdXNlcjoxMDAiLCJyblN0ciI6ImkyVnRzNVh1cGFRamVVQWhMQzQ2YnAxR0FVY2Zka0NOIiwiY2xpZW50aWQiOiJlNWNkN2U0ODkxYmY5NWQxZDE5MjA2Y2UyNGE3YjMyZSIsInRlbmFudElkIjoiMjAyMDA4MTMwNDQ0MTEiLCJ1c2VySWQiOjEwMCwidXNlck5hbWUiOiJhZG1pbiIsImRlcHRJZCI6MTAwLCJkZXB0TmFtZSI6IuS4reWFsea5luWNl-ecgeWnlOWFmuagoea5luWNl-ihjOaUv-WtpumZoiIsImRlcHRUeXBlIjoiMDEifQ.vl03dSMPY2Vkq-L1OJEpJgqN5NEkk2ig0ncxHfjrpwI");
             String url = "http://localhost:8001/dev-api/backstage/v1/Consumes/ConsumeOriginal";
             String bodyStr = bodyStr = JSONUtil.toJsonStr(recordBo);
             HttpResponse response = HttpRequest.post(url)