diff --git a/src/main/java/org/well/well/kafka/KafkaConsumer.java b/src/main/java/org/well/well/kafka/KafkaConsumer.java
index aca94ab..f46adce 100644
--- a/src/main/java/org/well/well/kafka/KafkaConsumer.java
+++ b/src/main/java/org/well/well/kafka/KafkaConsumer.java
@@ -41,7 +41,7 @@
             threadPool.execute(resp);
 //        resp.process(value);//对应的消息处理
 
-            Thread.sleep(100);
+            Thread.sleep(1000);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }

diff --git a/src/main/java/org/well/well/kafka/KafkaConsumer.java b/src/main/java/org/well/well/kafka/KafkaConsumer.java
index aca94ab..f46adce 100644
--- a/src/main/java/org/well/well/kafka/KafkaConsumer.java
+++ b/src/main/java/org/well/well/kafka/KafkaConsumer.java
@@ -41,7 +41,7 @@
             threadPool.execute(resp);
 //        resp.process(value);//对应的消息处理
 
-            Thread.sleep(100);
+            Thread.sleep(1000);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
diff --git a/src/main/resources/wellSensor/application.properties b/src/main/resources/wellSensor/application.properties
index 9bfb49f..108f4d2 100644
--- a/src/main/resources/wellSensor/application.properties
+++ b/src/main/resources/wellSensor/application.properties
@@ -172,7 +172,7 @@
 bootstrap.servers =  111.198.10.15:12502
 
 kafka.topic = pressure
-bootstrap.groupid = 6
+bootstrap.groupid = 7
 
 # ============================================================================
 # 告警、工单推送地址