[Bug] 1.3.3版本 数据订阅 以及 mqtt 问题
- Lingua principale
- Java
- Stelle
- 6.4k
- Fork
- 1.2k
- Merge medio
- 1g 23h
- PR unite (30g)
- 115
Descrizione
### Search before asking
- [x] I searched in the [issues](https://github.com/apache/iotdb/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!
Guida per i contributori
Apri la guida per i contributori
Direzione di ricerca
Inizia riproducendo il report con un client Java sottoscritto a ytStatus, facendo pubblicare a MQTT 100 messaggi e usando ./start-cli per ispezionare la sequenza inserita. Confronta la prima sottoscrizione con l’annullamento e la nuova sottoscrizione, inclusi gli insert tramite MQTT, timeseries e il percorso di insert riportato. Il lavoro è completato quando le sottoscrizioni ricevono in modo affidabile i messaggi appena accettati, inclusi i messaggi ricevuti dal server MQTT integrato di IoTDB.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- java
- Ambito
- databases
- Tipo di issue
- Bug
- Difficoltà
- 4/5
- Tempo stimato
- 3-5 giorni
- Stato di attività
- Ferma
- Chiarezza
- Abbastanza chiara
- Idoneità per principianti
- 30/100