2.0.7表模式下如何订阅实时数据

[nmgwr]

`

  // 创建 topics
    try (final ISubscriptionTableSession session =  new SubscriptionTableSessionBuilder()
                         .host(host)
                         .port(port)
                         .username(user)
                         .password(password)
                         .build())
    {
        final Properties config = new Properties();
        config.put(TopicConstant.DATABASE_KEY, "酸奶");
        config.put(TopicConstant.TABLE_KEY, "金山_产线_灌装_老酸奶灌装机");
        config.put(TopicConstant.START_TIME_KEY, "now");
        config.put(TopicConstant.STRICT_KEY, "true");
        config.put(TopicConstant.MODE_KEY, TopicConstant.MODE_DEFAULT_VALUE);
        session.createTopic("test_topic", config);
        log.info("主题 {} 创建成功", "test_topic");
    }

    ThreadUtil.execute(() -> {
        // 创建消费者
        // push 模式
        final ISubscriptionTablePushConsumer consumer = new SubscriptionTablePushConsumerBuilder()
                .consumerId("c1").consumerGroupId("cg1")
                .host(host).port(port)
                .username(user).password("root")
                .consumeListener(message -> {
                    System.out.println( message );
                    return ConsumeResult.SUCCESS;
                })
                .build();
        try {
            Thread.currentThread().join();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    });

`
以上代码中 我拿不到 实时数据。我的实时数据是通过iotdb 自带的 mqtt 写进去的。每次写进去 执行select 查询的时候已经查到新数据了。但是 这个订阅始终收不到数据。

[nmgwr]

文档是看的树模式下的（表模式下没有订阅相关文档） 代码是参考 仓库中的样例改成push模式的（样例是pull模式，pull模式测了 没问题）。是不支持表模式的push模式吗？

[nmgwr]

iotdb 是 本机docker 部署的。也不是收不到 是写入数据库之后 过一段时间 也许十分钟左右就能收到了。而且不是一条数据。

.consumeListener(message -> {
                        System.out.println( message );
                        return ConsumeResult.SUCCESS;
                    })

我理解应该是一条数据写入表中。这个回调方法会被出发一次。目前是写入数据之后十分钟左右这个方法被调用三次。每次的数据是一样的。