diff --git a/smallrye-reactive-messaging-mqtt/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java b/smallrye-reactive-messaging-mqtt/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java
index 5ccc166cdf..b975fc5fe9 100644
--- a/smallrye-reactive-messaging-mqtt/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java
+++ b/smallrye-reactive-messaging-mqtt/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java
@@ -120,11 +120,18 @@ public MqttClientSessionOptions setWillTopic(String willTopic) {
     }
 
     @Override
+    @Deprecated
     public MqttClientSessionOptions setWillMessage(String willMessage) {
         super.setWillMessage(willMessage);
         return this;
     }
 
+    @Override
+    public MqttClientOptions setWillMessageBytes(Buffer willMessage) {
+        super.setWillMessageBytes(willMessage);
+        return this;
+    }
+
     @Override
     public MqttClientSessionOptions setCleanSession(boolean cleanSession) {
         super.setCleanSession(cleanSession);