重发kfk失败消息

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/TrackJob.java

@@ -0,0 +1,31 @@
+package cn.com.ctop.job.bytedance.handler;
+
+
+import cn.com.ctop.job.bytedance.data.utils.HttpUtils;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+
+/**
+ * kafka异常数据处理
+ */
+@Slf4j
+@Component
+public class TrackJob {
+
+    /**
+     * kafka 重发失败消息
+     */
+    @XxlJob("sendAgainKfkinfo")
+    public void sendAgainKfkinfo() throws Exception {
+        String url = "https://track.artlinkworld.cn/information/sendAgainKfkinfo";
+        Map<String, Object> param = new HashMap<>();
+        param.put("id", "hr_3bf560ad31e50f2ff18e4490b37b20f8WU0l4zVgFsOoquFxmQwqfg8vtO");
+        String s = HttpUtils.httpGet(url, param, null);
+    }
+
+}