diff --git a/pom.xml b/pom.xml
index af787665d3d3f3903c365c766a10d0ef921c77be..94fabbab45ede9256d6c8c603fc2cbdd649b2fc2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -3,7 +3,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>tech.mhuang.pacebox</groupId>
     <artifactId>pacebox-kafka</artifactId>
-    <version>1.0.4</version>
+    <version>1.0.4.1</version>
     <packaging>jar</packaging>
     <name>kafka tool</name>
     <url>kafka plugin</url>
diff --git a/src/main/java/tech/mhuang/pacebox/kafka/consumer/generator/KafkaConsumerGenerator.java b/src/main/java/tech/mhuang/pacebox/kafka/consumer/generator/KafkaConsumerGenerator.java
index 23fe2446b99f9899ff3336a598c7f88585093c15..1abddea759bacfca556babd79ac3c263079ddf8a 100644
--- a/src/main/java/tech/mhuang/pacebox/kafka/consumer/generator/KafkaConsumerGenerator.java
+++ b/src/main/java/tech/mhuang/pacebox/kafka/consumer/generator/KafkaConsumerGenerator.java
@@ -50,7 +50,6 @@ public final class KafkaConsumerGenerator {
      * @param consumerBean 初始化
      */
     private static void initTopic(Map<String, Object> props, String topic, ConsumerBean consumerBean, List result) {
-        Map<String, Object> cloneProps = new HashMap<>(props);
         KafkaConsumer<Object, Object> consumer = new KafkaConsumer<>(props);
         List<PartitionInfo> partitionList = consumer.partitionsFor(topic);
         consumer.close();
@@ -69,10 +68,11 @@ public final class KafkaConsumerGenerator {
             operaParttionList.add(new TopicPartition(topic, partition));
             //解决除数为0的情况下
             if (crtParitionCount - 1 == i || i == 0 || (threadPartionNum - 1) % i == 0) {
+                Map<String, Object> cloneProps = new HashMap<>(props);
                 cloneProps.put("group.id", sb.insert(0, "-group-").insert(0, topic).toString());
                 result.add(initPartition(cloneProps, operaParttionList, topic, consumerBean));
-                operaParttionList = new ArrayList<>();
-                sb = new StringBuilder();
+                operaParttionList.clear();
+                sb.setLength(0);
             }
         }
     }