commit

apply.sh

@@ -1,5 +1,5 @@
 
-version="1.3"
+version="1.4"
 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

@@ -58,7 +58,7 @@ public class Main {
             consumer.subscribe(List.of("article"));
             while (true) {
                 var kafkaDataList = new ArrayList<KafkaData>();
-                for (ConsumerRecord<String, String> record : consumer.poll(Duration.ofMillis(30 * 1000))) {
+                for (ConsumerRecord<String, String> record : consumer.poll(Duration.ofMillis(20 * 1000))) {
                     kafkaDataList.add(new KafkaData(record.offset(), record.value(), new Timestamp(record.timestamp())));
                     var offsetMap = Map.of(new TopicPartition(record.topic(), record.partition()), new OffsetAndMetadata(record.offset()));
                     consumer.commitSync(offsetMap);