Skip to content

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

Open
@LiuooTime

Description

@LiuooTime

Search before asking

  • 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消息
image
3、./start-cli进入后台。查看消息,可以看到已经添加到序列中。
image
4、问题出现:ytStatus主题的消费者未能消费掉我mqtt发送的消息。
image
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?

  • I'm willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions