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

`

// 创建 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 查询的时候已经查到新数据了。但是 这个订阅始终收不到数据。

Bắt đầu bằng cách xem xét cấu hình topic ở chế độ bảng được truyền vào SubscriptionTableSessionBuilder và createTopic, sau đó theo dõi cách SubscriptionTablePushConsumerBuilder và consumeListener được kỳ vọng sẽ nhận các hàng được ghi thông qua IoTDB MQTT. Tái tạo thiết lập với các giá trị database, table và test_topic được hiển thị; hoàn tất khi consumer nhận được dữ liệu thời gian thực vừa được chèn.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.