commit

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

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