[Bug] 1.3.3版本 数据订阅 以及 mqtt 问题

[LiuooTime]

Search before asking

• [x] I searched in the issues and found nothing similar.

Version

1.3.3版本的数据订阅功能失效。 mqtt服务器的订阅功能失效。

Describe the bug and provide the minimal reproduce step

1、使用java连接iotdb，订阅主题ytStatus

2、使用mqtt发送100消息 3、./start-cli进入后台。查看消息，可以看到已经添加到序列中。 4、问题出现：ytStatus主题的消费者未能消费掉我mqtt发送的消息。 4.1:如果取消订阅ytStatus，在订阅ytStatus。就可以可以打印出 ystem.out.println("getColumnNames:=============================== " + next.getColumnNames()); System.out.println("deviceId:=========" + next.getTablet().deviceId); System.out.println("timestamps:=======" + next.getTablet().timestamps); System.out.println("values:===========" + next.getTablet().values); System.out.println("getColumnTypes:=============================== " + next.getColumnTypes()); 也就是在第一次订阅后，才会后效果。后面无论采用什么样的方式（mqtt\insert timesericer () ()这两种方法）向序列中添加测量点。都不会订阅到。

What did you expect to see?

2个问题： 1、1.3.3版本的 订阅模式只有在第一次订阅的时候，才会有效果。后面无论怎么添加数据都不能在实时的订阅到。 2、可以向iotdb发送mqtt协议的报文（iotdb内置了mqtt服务器）。但是不能监听iotdb接受的mqtt报文。 只能发布到时间序列里面。 不能订阅iotdb内置的mqtt服务器所接受的报文，舍弃了mqtt原有的订阅功能。

What did you see instead?

希望作者可以解决掉问题。

Anything else?

No response

Are you willing to submit a PR?

• [X] I'm willing to submit a PR!

[github-actions[bot]]

Hi, this is your first issue in IoTDB project. Thanks for your report. Welcome to join the community!

[VGalaxies]

1.3.3版本的 订阅模式只有在第一次订阅的时候，才会有效果。后面无论怎么添加数据都不能在实时的订阅到

./start-cli 进入后台后执行 flush 语句可以订阅到实时数据吗

[LiuooTime]

执行后仍然没有效果。

[CritasWang]

iotdb 内置的 mqtt 服务器，目前仅提供将数据写入 iotdb 的功能，不提供外部订阅。如果需要外部订阅可以考虑使用其他的 mqtt 服务器

[LiuooTime]

1.3.3版本的 订阅模式只有在第一次订阅的时候，才会有效果。后面无论怎么添加数据都不能在实时的订阅到

./start-cli 进入后台后执行 flush 语句可以订阅到实时数据吗

我现在切换到了2.0.2版本。 使用cli命名行工具插入一条数据。在使用flush是可以订阅到的。 但是我在5秒类插入10条数据，然后在flush,订阅监听器却只能拿到最新的一条。这个应该是没问题的。 每次flush才能订阅到。新增数据后，不flush。数据就订阅不到了。 目前我不flush订阅就成功了一次！！！，但是时间却相差了好几分钟。大多数情况数据都订阅不到。