[Bug] 1.3.3版本 数据订阅 以及 mqtt 问题
- Lenguaje dominante
- Java
- Estrellas
- 6.4k
- Forks
- 1.2k
- Merge medio
- 1 d 23 h
- PR fusionados (30 d)
- 115
Descripción
### 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!
Guía de contribución
Línea de trabajo
Comienza reproduciendo el informe con un cliente Java suscrito a ytStatus, haciendo que MQTT publique 100 mensajes y usando ./start-cli para inspeccionar la secuencia insertada. Compara la primera suscripción con la cancelación y la nueva suscripción, incluidos los inserts mediante MQTT, timeseries y la ruta de insert reportada. Se considera terminado cuando las suscripciones reciben de forma fiable los mensajes recién aceptados, incluidos los mensajes recibidos por el servidor MQTT integrado de IoTDB.
Escrito por el modelo de indexación a partir del texto del issue.
Evaluación
- Stack tecnológico
- java
- Área
- databases
- Tipo de issue
- Error
- Dificultad
- 4/5
- Tiempo estimado
- 3-5 días
- Estado de actividad
- Estancado
- Claridad
- Bastante claro
- Aptitud para principiantes
- 30/100