Java springboot mqtt

springboot集成mqtt问题

一个springboot项目，下图是我关于mqtt的依赖

<dependency>
            <groupId>org.springframework.integrationgroupId>
            <artifactId>spring-integration-streamartifactId>
        dependency>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starter-integrationartifactId>
        dependency>
        <dependency>
            <groupId>org.springframework.integrationgroupId>
            <artifactId>spring-integration-mqttartifactId>
        dependency>

我的mqtt回调类代码

@Component
@Slf4j
@EnableConfigurationProperties
public class MqttConsumerCallBack implements MqttCallback{

    @Value("${spring.mqtt.client.id}")
    private String ClientId;

    @Autowired
    private TestApi api;


    /**
     * 客户端断开连接的回调
     */
    @Override
    public void connectionLost(Throwable throwable) {
        System.out.println(ClientId+"与服务器断开连接，重新连接中-----");
    }

yml配置文件

    client:
      id: 1234
    default:
      topic: topic

当我的mqtt断开连接时，运行结果如下

null与服务器断开连接，重新连接中-----

不知道为什么ClientId没有读到配置文件里面的值

• 这篇博客也许可以解决你的问题👉 ：6. 使用SpringBoot来开发基于Java的MQTT客户端

望采纳。
你实现连接成功的方法，在里面打印一下你的 clientid，应该是你的 clientid 根本就没有读取到