修改文件存储路径

common-lib/src/main/java/com/mortals/xhx/queue/DefaultTbCoreConsumerService.java

@@ -70,7 +70,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<TbQueu
                         comsureQueue.offer(item);
                     }
 
-                    mainConsumer.commit();
+                    //mainConsumer.commit();
                     Thread.sleep(200);
                 } catch (Exception e) {
                     if (!stopped) {
@@ -111,7 +111,7 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<TbQueu
                             comsureQueue.offer(item);
                         }
 
-                        consumer.commit();
+                       // consumer.commit();
                         Thread.sleep(200);
                     } catch (Exception e) {
                         if (!stopped) {

common-lib/src/main/java/com/mortals/xhx/queue/kafka/AbstractTbQueueConsumerTemplate.java

@@ -148,7 +148,7 @@ public abstract class AbstractTbQueueConsumerTemplate<R, T extends TbQueueMsg> i
         }
     }
 
-    abstract protected List<R> doPoll(long durationInMillis) throws InterruptedException;
+    abstract protected List<R> doPoll(long durationInMillis);
 
     abstract protected T decode(R record);