订阅的触发时机是什么？

[StrongManLi]

我现在正在测试订阅相关的内容，使用了文档里的示例代码。现在测试的效果是：
当插入第一条数据时（创建Timeseries）会在控制台打印插入的数据。
当重新启动时会打印全部的数据（没设置起止时间）
但是在执行过程中并没有打印新插入的数据。

    private void pollConsumer (String topic, String host, Integer port) {
        final Properties config = new Properties();
        config.put(ConsumerConstant.CONSUMER_ID_KEY, "c2");
        config.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");

        final SubscriptionPullConsumer consumer1 = new SubscriptionPullConsumer(config);

        consumer1.open();
        consumer1.subscribe(topic);

//        Set<String> set = new HashSet<>();
//        set.add(topic);

        for (int i = 0;i < 100;i++) {
            LockSupport.parkNanos(500);
            final List<SubscriptionMessage> messages = consumer1.poll(1000);
            for (final SubscriptionMessage message : messages) {
                for (final SubscriptionSessionDataSet dataSet : message.getSessionDataSetsHandler()) {
                    System.out.println(dataSet.getColumnNames());
                    System.out.println(dataSet.getColumnTypes());
                    while (dataSet.hasNext()) {
                        System.out.println(dataSet.next());
                        Tablet tablet = dataSet.getTablet();
                    }
                }
            }
        }

        consumer1.unsubscribe(topic);
        consumer1.close();
    }

控制台打印

2041 [main] INFO  o.a.i.s.s.c.SubscriptionPullConsumer - SubscriptionPullConsumer SubscriptionPullConsumer{subscribedTopicNames=[topic01], consumerGroupId=cg1, isClosed=false, consumerId=c2, fileSaveDir=E:\test\TestUDF\iotdb-subscription, autoCommit=true} poll empty message from topics [topic01] after 1000 millisecond(s) 
[Time, root.sky.a.temperature]
[INT64, DOUBLE]
1735868811188	-1.0
1735868817134	-2.0
[Time, root.sky.a.temperature]
[INT64, DOUBLE]
1735869028109	-2.0
1735869030243	-2.0
3291 [main] INFO  o.a.i.s.s.c.SubscriptionPullConsumer - SubscriptionPullConsumer SubscriptionPullConsumer{subscribedTopicNames=[topic01], consumerGroupId=cg1, isClosed=false, consumerId=c2, fileSaveDir=E:\test\TestUDF\iotdb-subscription, autoCommit=true} poll empty message from topics [topic01] after 1000 millisecond(s) 
4140 [main] INFO  o.a.i.s.s.c.SubscriptionPullConsumer - SubscriptionPullConsumer SubscriptionPullConsumer{subscribedTopicNames=[topic01], consumerGroupId=cg1, isClosed=false, consumerId=c2, fileSaveDir=E:\test\TestUDF\iotdb-subscription, autoCommit=true} poll empty message from topics [topic01] after 1000 millisecond(s) 
...

在循环的过程中仅会在创建 timeseries 时打印新增的数据。

[VGalaxies]

新增的数据在 flush 后会触发订阅，可以在命令行中手动执行 flush 命令观察是否打印了新插入的数据

[StrongManLi]

好的，触发了