commit

build.gradle

@@ -3,10 +3,10 @@ plugins {
 }
 
 group 'org.example'
-version '1.0'
+version '1.0-SNAPSHOT'
 repositories {
     maven { url 'https://maven.aliyun.com/nexus/content/groups/public' }
-    mavenCentral()
+//    mavenCentral()
 }
 
 dependencies {

src/main/java/com/cxzx/Main.java

@@ -30,7 +30,6 @@ public class Main {
                 for (Map.Entry<String, List<KafkaData>> entry : CollStreamUtil.groupByKey(kafkaDataList, KafkaData::getTopic).entrySet()) {
                     Tidb.insert(entry.getValue(),entry.getKey());
                 }
-
                 consumer.commitSync();
             }
         } catch (Exception e) {