commit

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

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