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