Vert.x kafka消费者在获取记录之间暂停

import io.vertx.core.Vertx;
import io.vertx.kafka.client.consumer.KafkaConsumer;

public class KafkaConsumerExample {
    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();

        KafkaConsumer<String, String> consumer = KafkaConsumer.create(vertx, config);

        consumer.handler(record -> {
            // 处理记录
            System.out.println("Received record: " + record.value());

            // 暂停消费者
            consumer.pause();

            // 模拟耗时操作
            vertx.setTimer(5000, timerId -> {
                // 恢复消费者
                consumer.resume();
            });
        });

        consumer.subscribe("topic");

        // 启动消费者
        consumer.start();
    }
}