We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
1.3.3版本的数据订阅功能失效。 mqtt服务器的订阅功能失效。
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 () ()这两种方法)向序列中添加测量点。都不会订阅到。
2个问题: 1、1.3.3版本的 订阅模式只有在第一次订阅的时候,才会有效果。后面无论怎么添加数据都不能在实时的订阅到。 2、可以向iotdb发送mqtt协议的报文(iotdb内置了mqtt服务器)。但是不能监听iotdb接受的mqtt报文。 只能发布到时间序列里面。 不能订阅iotdb内置的mqtt服务器所接受的报文,舍弃了mqtt原有的订阅功能。
希望作者可以解决掉问题。
No response
The text was updated successfully, but these errors were encountered:
Hi, this is your first issue in IoTDB project. Thanks for your report. Welcome to join the community!
Sorry, something went wrong.
1.3.3版本的 订阅模式只有在第一次订阅的时候,才会有效果。后面无论怎么添加数据都不能在实时的订阅到
./start-cli 进入后台后执行 flush 语句可以订阅到实时数据吗
执行后仍然没有效果。
No branches or pull requests
Search before asking
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?
The text was updated successfully, but these errors were encountered: