diff --git a/src/supplemental/mqtt/mqtt_codec.c b/src/supplemental/mqtt/mqtt_codec.c
index 2dd277dd..737b3130 100644
--- a/src/supplemental/mqtt/mqtt_codec.c
+++ b/src/supplemental/mqtt/mqtt_codec.c
@@ -1954,7 +1954,7 @@ nni_mqtt_msg_decode_connack(nni_msg *msg)
 	}
 
 	/* Connect Return Code */
-	result = read_byte(&buf, &mqtt->var_header.connack.connack_flags);
+	result = read_byte(&buf, &mqtt->var_header.connack.conn_return_code);
 	if (result != 0) {
 		return MQTT_ERR_PROTOCOL;
 	}
@@ -1980,7 +1980,7 @@ nni_mqttv5_msg_decode_connack(nni_msg *msg)
 	}
 
 	/* Connect Return Code */
-	result = read_byte(&buf, &mqtt->var_header.connack.connack_flags);
+	result = read_byte(&buf, &mqtt->var_header.connack.conn_return_code);
 	if (result != 0) {
 		return MQTT_ERR_PROTOCOL;
 	}