一、该问题的重现步骤是什么？
1. broker集群模式，开启了3个，消费组配置mqtt协议，且mqtt连接信息是broker服务的。
2. 服务端订阅的消费组既有kafka，又有mqtt；
二、你期待的结果是什么？实际看到的又是什么？
mqtt消息大部分数据丢失，kafka数据偶尔丢失；
三、你正在使用的是什么产品，什么版本？在什么操作系统上？
物联网，v2.0.0，linux k8s部署
四、请提供详细的错误堆栈信息，这很重要。
tio的日志有can`t sent data
五、若有更多详细信息，请在下面提供。
密码这个错误已改正
你们每秒消息数量是多少，用【master分支最新版本】并且是 【单机模式】的情况下本地启动测试看下结果是多少。
另外请给我们邮箱：bladejava@qq.com 发一个邮件提供授权公司名以及你的社区帐号，登记为商业账号后方可进行商业版问题答疑。
每秒1万点位，本机测试单机模式半小时暂时没有发现问题；请问master的集群模式是存在问题吗？
奇怪了，你的意思是同样的环境和并发数，单机模式能扛住，集群模式出问题么？
生产环境是集群，我们无法连接生产测试单机模式，单机扛不住，只能集群；本机测试的单机模式数据量不大，怀疑mqtt连接在集群中是只能1个能成功，因为cliantId一致，有相互顶的？
不是这个问题，clientId带有时间戳不会重复的。而且连接mqtt集群的时候，负载到不同的服务节点上，客户端会自动重连。
现在你本地单机没问题的话，你也不用先看线上系统。你本地也启动集群模式来测试下(线上应该是2.2版本？那测试的话也先用2.2来试试)，看看数据量少和数据量多的情况下出问题的数量级差别是怎样的。
因为现在提供可判断的数据和信息还比较少，我们目前也无法找到原因是哪个。
加载中...
苏公网安备 32041102000998号