commit

apply.sh

@@ -1,5 +1,5 @@
 
-version="1.10"
+version="1.11"
 docker build -t registry.cn-chengdu.aliyuncs.com/cxzx-spider/ali-kafka:$version .
 docker push registry.cn-chengdu.aliyuncs.com/cxzx-spider/ali-kafka:$version
 sed -i "s!{ { image } }!registry\.cn-chengdu\.aliyuncs\.com/cxzx-spider/ali-kafka:$version!g" *.yml

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

@@ -22,7 +22,7 @@ public class Main {
         var consumer = new KafkaConsumer<String, String>(KafkaConfig.getKafkaProperties());
 
         try (consumer) {
-            consumer.subscribe(List.of("article","media_center_test"));
+            consumer.subscribe(List.of("article","material"));
             while (true) {
                 var kafkaDataList = new ArrayList<KafkaData>();
                 for (ConsumerRecord<String, String> record : consumer.poll(Duration.ofMillis(2000))) {