问题描述

1、 flink技术

2、实现接收mqtt主题数据，发送给另一个主题；

3、source与sink都是mqtt主题

问题是 mqtt作为source或sink 与mqtt客户端建立连接的时候，会创建很多clientid，为什么？ 按理说只有一个啊！

ahc开头的是source 有8个

publish开头的是sink 有8个

不理解，为什么呢？而且时间戳都是一样的

一开始我以为是client建立连接需要时间，异步或同步的问题，所以才短时间内建立多个连接

然后打印代码，发现source的run这里，居然运行了8次。

我想肯定不是mqtt建立连接的问题了

于是，我设置了并行度为1

运行，发现只run一次

连接主题的clientid也只有1个 source 1个sink 完美

我查看了我电脑的配置 逻辑处理器8个，我想 如果不设置并行度，默认就是电脑的配置吧

总结

你以为的原因，仅仅是你以为的，出了问题就证明你之前的思路有bug，甚至南辕北辙。

要学会全局分段分析问题，不要一直在一个胡同里面绕着