commit

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

@@ -21,7 +21,8 @@ public class Main {
         var consumer = new KafkaConsumer<String, String>(KafkaConfig.getKafkaConsumerProperties());
 
         try (consumer) {
-            consumer.subscribe(List.of("article_843ea558d5ef41a1877584c62762632d_app_35","material","article_843ea558d5ef41a1877584c62762632d_app"));
+            consumer.subscribe(List.of("article_843ea558d5ef41a1877584c62762632d_app_35","material",
+                    "article_843ea558d5ef41a1877584c62762632d_app","article_843ea558d5ef41a1877584c62762632d_app_84"));
             while (true) {
                 var kafkaDataList = new ArrayList<KafkaData>();
                 for (ConsumerRecord<String, String> record : consumer.poll(Duration.ofMillis(60000))) {